byte-stream
byte-stream copied to clipboard
Invalid non-string/buffer chunk
Am I doing something wrong in below example?
let { Writable } = require("stream");
let fs = require("fs");
var batcher = require('byte-stream');
let input = fs.createReadStream("./test-file");
let batchedStream = batcher({time:1000, limit:100})
let output = new Writable({
write: function writeImplementation(chunk, encoding, callback) {
console.log(` OUTPUT: "${chunk.toString().replace("\n", "\\n")}"`);
}
});
input
.pipe(batchedStream)
.pipe(output);