Function generateReadable

tests/setup/server.js:165–185

(length = 1024 * 1024, chunkSize = 10 * 1024, sleep = 50)

export const nodeVersion = process.versions.node.split('.').map((v) => parseInt(v, 10));

export const generateReadable = (length = 1024 * 1024, chunkSize = 10 * 1024, sleep = 50) => {
  return stream.Readable.from(
    (async function* () {
      let dataLength = 0;

      while (dataLength < length) {
        const leftBytes = length - dataLength;

        const chunk = Buffer.alloc(leftBytes > chunkSize ? chunkSize : leftBytes);

        dataLength += chunk.length;

        yield chunk;

        if (sleep) {
          await setTimeoutAsync(sleep);
        }
      }
    })()
  );
};

export const makeReadableStream = (chunk = 'chunk', n = 10, timeout = 100) => {
  return new ReadableStream(