Function testOndrain

test/parallel/test-stream-iter-push-writer.js:8–20

()

const { push, ondrain, text } = require('stream/iter');

async function testOndrain() {
  const { writer } = push({ highWaterMark: 1 });

  // With space available, ondrain resolves immediately
  const drainResult = ondrain(writer);
  assert.ok(drainResult instanceof Promise);
  const result = await drainResult;
  assert.strictEqual(result, true);

  // After close, ondrain returns null
  writer.end();
  assert.strictEqual(ondrain(writer), null);
}

async function testOndrainNonDrainable() {
  // Non-drainable objects return null