Function testDelayedPushes

test/parallel/test-stream-iter-readable-interop.js:135–153

()

// =============================================================================

async function testDelayedPushes() {
  let pushCount = 0;
  const readable = new Readable({
    read() {
      if (pushCount < 3) {
        setTimeout(() => {
          this.push(Buffer.from(`delayed${pushCount}`));
          pushCount++;
          if (pushCount === 3) {
            this.push(null);
          }
        }, 10);
      }
    },
  });

  const result = await text(from(readable));
  assert.strictEqual(result, 'delayed0delayed1delayed2');
}

// =============================================================================
// Byte-mode Readable: empty stream