Function createStream

packages/ui-default/service-worker.ts:8–22

(port)

const map = new Map();

function createStream(port) {
  return new ReadableStream({
    start(controller) {
      port.onmessage = ({ data }) => {
        if (data === 'end') return controller.close();
        if (data === 'abort') return controller.error('Aborted the download');
        return controller.enqueue(data);
      };
    },
    cancel(reason) {
      console.log('user aborted', reason);
      port.postMessage({ abort: true });
    },
  });
}

self.onmessage = (event) => {
  if (event.data === 'ping') return;