Creo un flujo de Buffer y Readable , con el objetivo de hacer que Readable consuma el Buffer .

El código es así:

 const { Readable } = require('stream'); // create a Buffer and allocate 200 positions to add the long text const buf = Buffer.alloc(200, 'this is a loooong text..'); const readStream = (buf_data) => { return new Readable({ read(size){ // I push the chunk data to the stream this.push(buf_data); // Here there MUST be a condition that will `push(null)` // end emit the 'end' event // ???? } }) } // Pass the Buffer to the readable stream read = readStream(buf) // the 'data' event is called to print the chunk data read.on('data', (chunk) => { console.log('chnk:', chunk.toString()) }) // the 'end' event, currently is not emitted, and the reading is not stopping. read.on('and', (chunk) => { console.log('--end--') })

Cuando ejecuto la aplicación (nodo <filename> ), la aplicación sigue leyendo e imprimiendo el text . Debería haber una condición que pueda agregar al método read() para hacer que el evento end se active**