Backpressuring in Streams

stream-backpressuring-example.js

const Readable = require('stream').Readable;
const Writable = require('stream').Writable;

let counter = 0;

const readable = new Readable({
  read(size) {
    counter++;

    this.push(counter.toString());

    if (counter >= 100) {
      this.push(null);
      return
    }
  }
});

const writable = new Writable({
  write(chunk, encoding, callback) {
    console.log('===================');
    callback();
  }
});

readable.pipe(writable);

docs: https://nodejs.org/en/docs/guides/backpressuring-in-streams/