asyncReadableStream.js

const { Readable } = require('stream');

class RandomNumberStream extends Readable {
    constructor(options) {
        super(options);

        this.isTimeToEndIt = false;
        setTimeout(() => {
            this.isTimeToEndIt = true;
        }, 10 * 1000);
    }

    async _read() {
        await new Promise(resolve => {
            setTimeout(resolve, 1000);
        });
        if (this.isTimeToEndIt) {
            this.push(null);
            return;
        }

        const randomNumberString = String(Math.floor(Math.random() * 10 + 1));
        this.push(`${randomNumberString}\n`);
    }
}

const randomNumbers = new RandomNumberStream();
randomNumbers.pipe(process.stdout);