Function makeReadableStream

tests/setup/server.js:187–199

(chunk = 'chunk', n = 10, timeout = 100)

};

export const makeReadableStream = (chunk = 'chunk', n = 10, timeout = 100) => {
  return new ReadableStream(
    {
      async pull(controller) {
        await setTimeoutAsync(timeout);
        n-- ? controller.enqueue(chunk) : controller.close();
      },
    },
    {
      highWaterMark: 1,
    }
  );
};

export const makeEchoStream = (echo) =>
  new WritableStream({