edgetunnel/test.mjs

import { ReadableStream } from 'stream/web';

function delay(ms) {
  return new Promise((resolve, rej) => {
    setTimeout(resolve, ms);
  });
}
try {
  let i = 0;
  const readableStream = new ReadableStream({
    start(control) {
      control.enqueue(undefined);
      control.enqueue(1);
      // control.close();
      control.error('eroro000-----readableStream--------');
      // setTimeout(() => {
      //   console.log('-----------------100');
      //   control.error('eroro000-----readableStream--------');
      // }, 100);
      // setInterval(() => {
      //   control.enqueue(i++);
      // }, 100);
      // setTimeout(() => {
      //   control.error('read error');
      // }, 1000);
    },
    pull(control) {
      // control.enqueue('11');
      // undefined.length;
      // control.close();
      //   control.error('error');
      //   undefined.length;
    },
    cancel(reason) {
      console.log('-ReadableStream---cancel-----', reason);
    },
  });

  setTimeout(() => {
    console.log('cancel');
  }, 2000);

  await readableStream.pipeTo(
    new WritableStream({
      async write(chunk, controller) {
        console.log(chunk);
        // throw 'pipeTo error';
        // controller.error('pipeTo has error');
        // await delay(1);
        // controller.error('error');
        // if (chunk === 7) {
        //   throw 'error';
        // }
      },
      close() {
        console.log('close------WritableStream');
      },
      abort(reason) {
        console.log('abort--------', reason);
      },
    })
  );

  // console.log('end--------');

  //   for await (const iterator of readableStream) {
  //     console.log(iterator);
  //   }
} catch (error) {
  console.log('---end---', error);
}