mirrors/cobalt
1
0
Fork 0
mirror of https://github.com/imputnet/cobalt.git synced 2025-12-16 13:08:52 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

merge: 10.6 updates
Some checks failed
Run tests / check lockfile correctness (push) Has been cancelled
Details
Run tests / web sanity check (push) Has been cancelled
Details
Run tests / api sanity check (push) Has been cancelled
Details
CodeQL / Analyze (${{ matrix.language }}) (none, javascript-typescript) (push) Has been cancelled
Details
Run service tests / test service functionality (push) Has been cancelled
Details
Run service tests / test service: ${{ matrix.service }} (push) Has been cancelled
Details

Browse Source
This commit is contained in:
jj
2025-01-21 13:34:19 +00:00
parent 192635f2ce 8d3db909d9
commit c4c47bdc27
25 changed files with 466 additions and 79 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
api/src/stream/internal.js
View File

@@ -7,7 +7,7 @@ const CHUNK_SIZE = BigInt(8e6); // 8 MB
const min = (a, b) => a < b ? a : b;
async function* readChunks(streamInfo, size) {
let read = 0n;
let read = 0n, chunksSinceTransplant = 0;
while (read < size) {
if (streamInfo.controller.signal.aborted) {
throw new Error("controller aborted");
@@ -22,6 +22,16 @@ async function* readChunks(streamInfo, size) {
signal: streamInfo.controller.signal
});
if (chunk.statusCode === 403 && chunksSinceTransplant >= 3 && streamInfo.transplant) {
chunksSinceTransplant = 0;
try {
await streamInfo.transplant(streamInfo.dispatcher);
continue;
} catch {}
}
chunksSinceTransplant++;
const expected = min(CHUNK_SIZE, size - read);
const received = BigInt(chunk.headers['content-length']);