nodejs
diff --git a/‎lib/internal/webstreams/readablestream.js‎
Lines changed: 7 additions & 3 deletions b/‎lib/internal/webstreams/readablestream.js‎
Lines changed: 7 additions & 3 deletions
@@ -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);
     });
   }