diff --git a/lib/internal/webstreams/readablestream.js b/lib/internal/webstreams/readablestream.js index 876e3a5bf6e2f0..3d0cd213bb158a 100644 --- a/lib/internal/webstreams/readablestream.js +++ b/lib/internal/webstreams/readablestream.js @@ -47,6 +47,10 @@ const { DOMException, } = internalBinding('messaging'); +const { + markPromiseAsHandled, +} = internalBinding('util'); + const { isArrayBufferView, isDataView, @@ -1569,9 +1573,9 @@ function readableStreamPipeTo( } // Write the chunk - we're already in a separate microtask from enqueue - // because we awaited writer[kState].ready.promise above + // because we awaited writer[kState].ready.promise above. state.currentWrite = writableStreamDefaultWriterWrite(writer, chunk); - setPromiseHandled(state.currentWrite); + markPromiseAsHandled(state.currentWrite); // Check backpressure after each write if (dest[kState].backpressure) { @@ -1675,7 +1679,7 @@ class PipeToReadableStreamReadRequest { // "ReadableStreamPipeTo" step 15's "chunk steps". queueMicrotask(() => { this.state.currentWrite = writableStreamDefaultWriterWrite(this.writer, chunk); - setPromiseHandled(this.state.currentWrite); + markPromiseAsHandled(this.state.currentWrite); this.promise.resolve(false); }); }