fixup! stream: add diagnostics_channel event for completion

Signed-off-by: Bryan English <[email protected]>

Author: bengl

lib/internal/webstreams/readablestream.js

@@ -501,8 +501,11 @@ class ReadableStream {
       }
       const promise = PromiseWithResolvers();
 
-      // eslint-disable-next-line no-use-before-define
-      readableStreamDefaultReaderRead(reader, new ReadableStreamAsyncIteratorReadRequest(reader, state, promise, stream, channel));
+      readableStreamDefaultReaderRead(
+        reader,
+        // eslint-disable-next-line no-use-before-define
+        new ReadableStreamAsyncIteratorReadRequest(reader, state, promise, stream, channel),
+      );
       return promise.promise;
     }
 

test/parallel/test-whatwg-webstreams-dc-events.mjs

@@ -38,7 +38,8 @@ import * as dc from 'diagnostics_channel';
   });
   channel.subscribe(subscriber);
 
-  for await (const _ of readable) {}
+  // eslint-disable-next-line no-unused-vars
+  for await (const _ of readable) { /* drain */ }
 
   channel.unsubscribe(subscriber);
 }