123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566
// deno-fmt-ignore-file// deno-lint-ignore-file
// Copyright Joyent and Node contributors. All rights reserved. MIT license.// Taken from Node 16.13.0// This file is automatically generated by "node/_tools/setup.ts". Do not modify this file manually
'use strict';
const common = require('../common');const assert = require('assert');const { Readable } = require('stream');
let ticks = 18;let expectedData = 19;
const rs = new Readable({  objectMode: true,  read: () => {    if (ticks-- > 0)      return process.nextTick(() => rs.push({}));    rs.push({});    rs.push(null);  }});
rs.on('end', common.mustCall());readAndPause();
function readAndPause() {  // Does a on(data) -> pause -> wait -> resume -> on(data) ... loop.  // Expects on(data) to never fire if the stream is paused.  const ondata = common.mustCall((data) => {    rs.pause();
    expectedData--;    if (expectedData <= 0)      return;
    setImmediate(function() {      rs.removeListener('data', ondata);      readAndPause();      rs.resume();    });  }, 1); // Only call ondata once
  rs.on('data', ondata);}
{  const readable = new Readable({    read() {}  });
  function read() {}
  readable.setEncoding('utf8');  readable.on('readable', read);  readable.removeListener('readable', read);  readable.pause();
  process.nextTick(function() {    assert(readable.isPaused());  });}