Function reef

test/delay-test.js:26–38

(n = 1)

// A promise-based barrier.
function reef(n = 1) {
  const done = helpers.deferred(),
    end = done.defer();
  return {
    done,
    next() {
      --n;
      if (n < 0) return false;
      if (n === 0) end();
      return true;
    },
  };
}

describe('Delayed jobs', (it) => {
  const redisUrl = process.env.BEE_QUEUE_TEST_REDIS || 'redis://localhost:6379';