producer-consumer.js

class Producer {
  start(consumer) {
    consumer.start(this);
    this.counter = 0;
    this.handler = setInterval(() => consumer.data(this.counter++), 1000);
  }

  stop() {
    clearInterval(this.handler);
  }
}

class Consumer {
  start(producer) {
    setTimeout(() => producer.stop(), 3500);
  }
  data(payload) {
    console.log(payload);
  }
}

const p = new Producer();
const c = new Consumer();

p.start(c);