feedback

index.bs

@@ -3459,16 +3459,16 @@ The following abstract operations support the implementation of the
      |pullIntoDescriptor|'s [=pull-into descriptor/bytes filled=].
   1. Let |descriptorBuffer| be |pullIntoDescriptor|'s [=pull-into descriptor/buffer=].
   1. Let |queueBuffer| be |headOfQueue|'s [=readable byte stream queue entry/buffer=].
+  1. Let |queueByteOffset| be |headOfQueue|'s [=readable byte stream queue entry/byte offset=].
   1. Assert: ! [$CanCopyDataBlockBytes$](|descriptorBuffer|, |destStart|, |queueBuffer|,
-     |headOfQueue|'s [=readable byte stream queue entry/byte offset=], |bytesToCopy|) is true.
+     |queueByteOffset|, |bytesToCopy|) is true.
      <p class="warning">If this assertion were to fail (due to a bug in this specification or
      its implementation), then the next step may read from or write to potentially invalid memory.
      The user agent should always check this assertion, and stop in an [=implementation-defined=]
      manner if it fails (e.g. by crashing the process, or by
      <a abstract-op lt="ReadableByteStreamControllerError">erroring the stream</a>).
   1. Perform ! [$CopyDataBlockBytes$](|descriptorBuffer|.\[[ArrayBufferData]], |destStart|,
-     |queueBuffer|.\[[ArrayBufferData]], |headOfQueue|'s [=readable byte stream queue entry/byte
-     offset=], |bytesToCopy|).
+     |queueBuffer|.\[[ArrayBufferData]], |queueByteOffset|, |bytesToCopy|).
   1. If |headOfQueue|'s [=readable byte stream queue entry/byte length=] is |bytesToCopy|,
    1. [=list/Remove=] |queue|[0].
   1. Otherwise,

reference-implementation/lib/abstract-ops/readable-streams.js

@@ -1362,7 +1362,7 @@ function ReadableByteStreamControllerEnqueue(controller, chunk) {
     ReadableByteStreamControllerEnqueueChunkToQueue(controller, transferredBuffer, byteOffset, byteLength);
     const filledPullIntos = ReadableByteStreamControllerProcessPullIntoDescriptorsUsingQueue(controller);
     for (const filledPullInto of filledPullIntos) {
-      ReadableByteStreamControllerCommitPullIntoDescriptor(controller._stream, filledPullInto);
+      ReadableByteStreamControllerCommitPullIntoDescriptor(stream, filledPullInto);
     }
   } else {
     assert(IsReadableStreamLocked(stream) === false);
@@ -1448,9 +1448,12 @@ function ReadableByteStreamControllerFillPullIntoDescriptorFromQueue(controller,
 
     const destStart = pullIntoDescriptor.byteOffset + pullIntoDescriptor.bytesFilled;
 
-    assert(CanCopyDataBlockBytes(pullIntoDescriptor.buffer, destStart, headOfQueue.buffer, headOfQueue.byteOffset,
+    const descriptorBuffer = pullIntoDescriptor.buffer;
+    const queueBuffer = headOfQueue.buffer;
+    const queueByteOffset = headOfQueue.byteOffset;
+    assert(CanCopyDataBlockBytes(descriptorBuffer, destStart, queueBuffer, queueByteOffset,
                                  bytesToCopy));
-    CopyDataBlockBytes(pullIntoDescriptor.buffer, destStart, headOfQueue.buffer, headOfQueue.byteOffset, bytesToCopy);
+    CopyDataBlockBytes(descriptorBuffer, destStart, queueBuffer, queueByteOffset, bytesToCopy);
 
     if (headOfQueue.byteLength === bytesToCopy) {
       queue.shift();
@@ -1680,11 +1683,9 @@ function ReadableByteStreamControllerRespondInClosedState(controller, firstDescr
   const stream = controller._stream;
   if (ReadableStreamHasBYOBReader(stream) === true) {
     const filledPullIntos = [];
-    let i = 0;
-    while (i < ReadableStreamGetNumReadIntoRequests(stream)) {
+    while (filledPullIntos.length < ReadableStreamGetNumReadIntoRequests(stream)) {
       const pullIntoDescriptor = ReadableByteStreamControllerShiftPendingPullInto(controller);
       filledPullIntos.push(pullIntoDescriptor);
-      ++i;
     }
     for (const filledPullInto of filledPullIntos) {
       ReadableByteStreamControllerCommitPullIntoDescriptor(stream, filledPullInto);