Skip to content

Commit 5a9965a

Browse files
committed
quic: Change streaming implementation and various bugfixes
1 parent 8f2401c commit 5a9965a

File tree

11 files changed

+278
-253
lines changed

11 files changed

+278
-253
lines changed

lib/internal/blob.js

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -475,6 +475,14 @@ function createBlobReaderStream(reader) {
475475
if (buffer !== undefined && buffer.byteLength !== 0) {
476476
c.enqueue(new Uint8Array(buffer));
477477
}
478+
if (status === 2) {
479+
// status block!
480+
// the source will call us (this function!) again !
481+
// we should not schedule another readnext,
482+
// as we end up in a busy loop, calling pull over and
483+
// over and pilling up next callbacks in dataqueue
484+
return;
485+
}
478486
// We keep reading until we either reach EOS, some error, or we
479487
// hit the flow rate of the stream (c.desiredSize).
480488
// We use set immediate here because we have to allow the event

0 commit comments

Comments
 (0)