NodeJS Stream

example-writable-constructor.js

const { Writable } = require("stream");

const myWritableStream = (data) => {

    return new Writable({

        write(chunk, enc, next) {
            data.push(chunk);
            next();
        }
    })
}

const data = [];
const writable  = myWritableStream(data);

writable.on('finish', () => {
    console.log('Writing Done!!!', data.toString());
})

writable.write("This is the stream data 1\n");
writable.write("This is the stream data 2\n");
writable.write("This is the stream data 3\n");

writable.end("Done!!!!");