summaryrefslogtreecommitdiff
path: root/client-web/source/sw/worker.ts
diff options
context:
space:
mode:
authormetamuffin <metamuffin@disroot.org>2022-10-26 23:59:30 +0200
committermetamuffin <metamuffin@disroot.org>2022-10-26 23:59:30 +0200
commite339287a7e9b6714d5ea4cdfd3fc80556d497e5c (patch)
treefbfa6fc44224898037d66001e8b2a0497ac5ba6a /client-web/source/sw/worker.ts
parent2a83c8bdbdd5a67b6068420520e83524f4a6f6bd (diff)
downloadkeks-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.ts5
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 }) },
})