From 3fddaf8fae1cd655466b6237a70ee81a13003537 Mon Sep 17 00:00:00 2001
From: Mattias Buelens <mattias@buelens.com>
Date: Thu, 22 Mar 2018 12:26:27 +0100
Subject: [PATCH] Readable byte stream must call pull if needed after receiving
 new chunk

After a readable byte stream receives a new chunk from the underlying source, the stream must call pull() (if needed). Otherwise, the stream may get stuck.

Add calls to ReadableByteStreamControllerCallPullIfNeeded at the end of ReadableByteStreamControllerEnqueue and ReadableByteStreamControllerRespondInternal to ensure this.

Fixes #877.
---
 index.bs                                        | 2 ++
 reference-implementation/lib/readable-stream.js | 4 ++++
 reference-implementation/web-platform-tests     | 2 +-
 3 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/index.bs b/index.bs
index 3ee835cd4..944836f09 100644
--- a/index.bs
+++ b/index.bs
@@ -2428,6 +2428,7 @@ nothrow>ReadableByteStreamControllerEnqueue ( <var>controller</var>, <var>chunk<
     1. Assert: ! IsReadableStreamLocked(_stream_) is *false*.
     1. Perform ! ReadableByteStreamControllerEnqueueChunkToQueue(_controller_, _transferredBuffer_, _byteOffset_,
        _byteLength_).
+  1. Perform ! ReadableByteStreamControllerCallPullIfNeeded(_controller_).
 </emu-alg>
 
 <h4 id="readable-byte-stream-controller-enqueue-chunk-to-queue" aoid="ReadableByteStreamControllerEnqueueChunkToQueue"
@@ -2654,6 +2655,7 @@ throws>ReadableByteStreamControllerRespondInternal ( <var>controller</var>, <var
   1. Otherwise,
     1. Assert: _stream_.[[state]] is `"readable"`.
     1. Perform ? ReadableByteStreamControllerRespondInReadableState(_controller_, _bytesWritten_, _firstDescriptor_).
+  1. Perform ! ReadableByteStreamControllerCallPullIfNeeded(_controller_).
 </emu-alg>
 
 <h4 id="readable-byte-stream-controller-respond-with-new-view" aoid="ReadableByteStreamControllerRespondWithNewView"
diff --git a/reference-implementation/lib/readable-stream.js b/reference-implementation/lib/readable-stream.js
index 515aa9195..49ab7d723 100644
--- a/reference-implementation/lib/readable-stream.js
+++ b/reference-implementation/lib/readable-stream.js
@@ -1671,6 +1671,8 @@ function ReadableByteStreamControllerRespondInternal(controller, bytesWritten) {
 
     ReadableByteStreamControllerRespondInReadableState(controller, bytesWritten, firstDescriptor);
   }
+
+  ReadableByteStreamControllerCallPullIfNeeded(controller);
 }
 
 function ReadableByteStreamControllerShiftPendingPullInto(controller) {
@@ -1764,6 +1766,8 @@ function ReadableByteStreamControllerEnqueue(controller, chunk) {
     assert(IsReadableStreamLocked(stream) === false);
     ReadableByteStreamControllerEnqueueChunkToQueue(controller, transferredBuffer, byteOffset, byteLength);
   }
+
+  ReadableByteStreamControllerCallPullIfNeeded(controller);
 }
 
 function ReadableByteStreamControllerError(controller, e) {
diff --git a/reference-implementation/web-platform-tests b/reference-implementation/web-platform-tests
index 81468a0b8..6e1b5f449 160000
--- a/reference-implementation/web-platform-tests
+++ b/reference-implementation/web-platform-tests
@@ -1 +1 @@
-Subproject commit 81468a0b88d771af9dfa0feb5de99367e32d4b6e
+Subproject commit 6e1b5f44943705380487dc73b96b4c959487ee4d