fixup! stream: readable read one buffer at a time

Author: ronag

test/parallel/test-stream-readable-needReadable.js

@@ -32,12 +32,11 @@ const asyncReadable = new Readable({
 });
 
 asyncReadable.on('readable', common.mustCall(() => {
-  if (asyncReadable.read() !== null) {
-    // After each read(), the buffer is empty.
-    // If the stream doesn't end now,
-    // then we need to notify the reader on future changes.
-    assert.strictEqual(asyncReadable._readableState.needReadable, true);
+  while (asyncReadable.read() !== null) {
   }
+  // If the stream doesn't end now,
+  // then we need to notify the reader on future changes.
+  assert.strictEqual(asyncReadable._readableState.needReadable || asyncReadable._readableState.ended, true);
 }, 2));
 
 process.nextTick(common.mustCall(() => {

test/parallel/test-webstreams-pipeline.js

@@ -181,7 +181,7 @@ const http = require('http');
   });
 
   pipeline(rs, t, ws, common.mustSucceed(() => {
-    assert.deepStrictEqual(values, ['HELLOWORLD']);
+    assert.deepStrictEqual(values, ['HELLO', 'WORLD']);
   }));
 
   c.enqueue('hello');