diff options
author | metamuffin <metamuffin@disroot.org> | 2022-10-13 09:11:56 +0200 |
---|---|---|
committer | metamuffin <metamuffin@disroot.org> | 2022-10-13 09:11:56 +0200 |
commit | bc8bba637e51d1c813c3edcf8747991dc69319e9 (patch) | |
tree | dba56c517f5de623ce46ec18a065cc274d8e92dc /client-web/source/resource/file.ts | |
parent | c8ac1b899f7a79898b3ec84157db642051e8e1ae (diff) | |
download | keks-meet-bc8bba637e51d1c813c3edcf8747991dc69319e9.tar keks-meet-bc8bba637e51d1c813c3edcf8747991dc69319e9.tar.bz2 keks-meet-bc8bba637e51d1c813c3edcf8747991dc69319e9.tar.zst |
modify client-web to not sent big messages
Diffstat (limited to 'client-web/source/resource/file.ts')
-rw-r--r-- | client-web/source/resource/file.ts | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/client-web/source/resource/file.ts b/client-web/source/resource/file.ts index 6cf3ff6..18a1ac7 100644 --- a/client-web/source/resource/file.ts +++ b/client-web/source/resource/file.ts @@ -9,6 +9,8 @@ import { ebutton, ediv, espan, sleep } from "../helper.ts"; import { log } from "../logger.ts"; import { LocalResource, ResourceHandlerDecl } from "./mod.ts"; +const MAX_CHUNK_SIZE = 1 << 15; + export const resource_file: ResourceHandlerDecl = { kind: "file", new_remote(info, user, enable) { @@ -111,11 +113,13 @@ function file_res_inner(file: File): LocalResource { return channel.close() } const feed = async () => { - const { value: chunk, done } = await reader.read() + const { value: chunk, done }: { value: Uint8Array, done: boolean } = await reader.read() if (done) return await finish() if (!chunk) console.warn("no chunk"); position += chunk.length - channel.send(chunk) + for (let i = 0; i < chunk.length; i += MAX_CHUNK_SIZE) { + channel.send(chunk.slice(i, Math.min(i + MAX_CHUNK_SIZE, chunk.length))) + } display.status = `${position} / ${file.size} (buffer: ${channel.bufferedAmount})` } const feed_until_full = async () => { |