ForbesLindesay

const Queue = require('then-queue'); // async queue that doesn't care what order you call push and pop.

const queue = new Queue();

// push sends to the first waiting `pop` if available, otherwise it acts as a buffer
listenToNewMessages(message => queue.push(message));

async function* MessagesGenerator() {
  try {
    while (true) {