Node Cookbook - Third Edition

How to do it...

We'll start of by requiring from2 and to2:

const from = require('from2') const to = require('to2') 

Next let's create our readable stream:

const rs = from(() => {   rs.push(Buffer.from('Hello, World!'))   rs.push(null)  }) 

To consume data from the stream, we either need to attach a data listener or pipe the stream to a writable stream.

As an intermediate step to check our stream, we can add a data listener like so:

rs.on('data', (data) => {   console.log(data.toString())  }) 

Now let's try running our program:

$ node index.js 

We should see that the readable stream prints out the Hello, World! message, via the data event listener.

But we're not done! Let's comment out the data handler, like so:

// rs.on('data', (data) => { // ...