node.js-stream – Tarik Billa

How to pipe one readable stream into two writable streams at once in Node.js?

September 18, 2023 by Tarik

Pipe chaining/splitting doesn’t work like you’re trying to do here, sending the first to two different subsequent steps: sourceFileStream.pipe(gzip).pipe(response); However, you can pipe the same readable stream into two writeable streams, eg: var fs = require(‘fs’); var source = fs.createReadStream(‘source.txt’); var dest1 = fs.createWriteStream(‘dest1.txt’); var dest2 = fs.createWriteStream(‘dest2.txt’); source.pipe(dest1); source.pipe(dest2);

How to wrap a buffer as a stream2 Readable stream?

February 27, 2023 by Tarik

The easiest way is probably to create a new PassThrough stream instance, and simply push your data into it. When you pipe it to other streams, the data will be pulled out of the first stream. var stream = require(‘stream’); // Initiate the source var bufferStream = new stream.PassThrough(); // Write your buffer bufferStream.end(Buffer.from(‘Test data.’)); … Read more

How to implement a writable stream

February 19, 2023 by Tarik

To create your own writable stream, you have three possibilities. Create your own class For this you’ll need: To extend the Writable class. To call the Writable constructor in your own constructor. To define a _write() method in the prototype of your stream object. Here’s an example: var stream = require(‘stream’); var util = require(‘util’); … Read more

Node.js Piping the same readable stream into multiple (writable) targets

January 15, 2023 by Tarik

You have to create duplicate of the stream by piping it to two streams. You can create a simple stream with a PassThrough stream, it simply passes the input to the output. const spawn = require(‘child_process’).spawn; const PassThrough = require(‘stream’).PassThrough; const a = spawn(‘echo’, [‘hi user’]); const b = new PassThrough(); const c = new … Read more