Re: [whatwg/streams] Refactor TransformStream's backpressure handling (#571)

isonmad commented on this pull request.



> @@ -363,14 +386,18 @@ module.exports = class TransformStream {
 
     this._readable = new ReadableStream(source, transformer.readableStrategy);
 
-    const sink = new TransformStreamSink(this, startPromise);
+    const sink = new TransformStreamSink(this, startPromise.then(() => {
+      return TransformStreamBackpressureGonePromise(this);
+    }));

The change isn't fully reverted; the original explanatory comment is gone, and the code didn't need to be in a block per [ricea's review at the original PR](https://github.com/whatwg/streams/pull/550#discussion_r84678242).

-- 
You are receiving this because you are subscribed to this thread.
Reply to this email directly or view it on GitHub:
https://github.com/whatwg/streams/pull/571