diff options
author | metamuffin <metamuffin@disroot.org> | 2022-10-26 23:59:30 +0200 |
---|---|---|
committer | metamuffin <metamuffin@disroot.org> | 2022-10-26 23:59:30 +0200 |
commit | e339287a7e9b6714d5ea4cdfd3fc80556d497e5c (patch) | |
tree | fbfa6fc44224898037d66001e8b2a0497ac5ba6a /client-web/source/sw/worker.ts | |
parent | 2a83c8bdbdd5a67b6068420520e83524f4a6f6bd (diff) | |
download | keks-meet-e339287a7e9b6714d5ea4cdfd3fc80556d497e5c.tar keks-meet-e339287a7e9b6714d5ea4cdfd3fc80556d497e5c.tar.bz2 keks-meet-e339287a7e9b6714d5ea4cdfd3fc80556d497e5c.tar.zst |
stream download proof-of-concept
Diffstat (limited to 'client-web/source/sw/worker.ts')
-rw-r--r-- | client-web/source/sw/worker.ts | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/client-web/source/sw/worker.ts b/client-web/source/sw/worker.ts index 25f6bab..5c185f3 100644 --- a/client-web/source/sw/worker.ts +++ b/client-web/source/sw/worker.ts @@ -47,12 +47,11 @@ function port_to_readable(port: MessagePort): ReadableStream { return new ReadableStream({ start(controller) { console.log("ReadableStream started"); - port.addEventListener("message", event => { - console.log(event.data); + port.onmessage = event => { if (event.data === "end") { controller.close() } else if (event.data === "abort") controller.error("aborted") else controller.enqueue(event.data) - }) + } }, cancel() { console.log("ReadableStream cancelled"); port.postMessage({ abort: true }) }, }) |