const fs = require('fs');
const Stream = require('stream')

const readableStream = new Stream.Readable(
    { read() { } }
);
const readableStream2 = fs.createReadStream('sample.txt');

const writableStream = new Stream.Writable(
    {
        write(chunk, encoding, next) {
            console.log(chunk.toString())
            next()
        }
    }
);

readableStream.pipe(writableStream);

readableStream.on('readable', () => {
    console.log(readableStream.read());
});

writableStream.write('Hello...');
writableStream.end();