nodejs
diff --git a/‎lib/internal/streams/iter/pull.js‎
Lines changed: 0 additions & 10 deletions b/‎lib/internal/streams/iter/pull.js‎
Lines changed: 0 additions & 10 deletions
diff --git a/‎test/parallel/test-stream-iter-pipeto.js‎
Lines changed: 27 additions & 0 deletions b/‎test/parallel/test-stream-iter-pipeto.js‎
Lines changed: 27 additions & 0 deletions
@@ -946,11 +946,6 @@ function pull(source, ...args) {
 function pipeToSync(source, ...args) {
   const { transforms, writer, options } = parsePipeToArgs(args, 'writeSync');
 
-  // Handle transform-writer
-  if (isTransformObject(writer)) {
-    ArrayPrototypePush(transforms, writer);
-  }
-
   // Normalize source and create pipeline
   const normalized = fromSync(source);
   const pipeline = transforms.length > 0 ?
@@ -1017,11 +1012,6 @@ async function pipeTo(source, ...args) {
     validateAbortSignal(options.signal, 'options.signal');
   }
 
-  // Handle transform-writer
-  if (isTransformObject(writer)) {
-    ArrayPrototypePush(transforms, writer);
-  }
-
   const signal = options?.signal;
 
   // Check for abort
 
@@ -141,6 +141,31 @@ async function testPipeToSyncWithTransforms() {
   assert.strictEqual(chunks.join(''), 'HELLO');
 }
 
+async function testPipeToWriterTransformMethodIgnored() {
+  const chunks = [];
+  const writer = {
+    transform: common.mustNotCall(),
+    write(chunk) { chunks.push(new TextDecoder().decode(chunk)); },
+  };
+
+  await pipeTo(from('hello'), writer);
+  assert.strictEqual(chunks.join(''), 'hello');
+}
+
+async function testPipeToSyncWriterTransformMethodIgnored() {
+  const chunks = [];
+  const writer = {
+    transform: common.mustNotCall(),
+    writeSync(chunk) {
+      chunks.push(new TextDecoder().decode(chunk));
+      return true;
+    },
+  };
+
+  pipeToSync(fromSync('hello'), writer);
+  assert.strictEqual(chunks.join(''), 'hello');
+}
+
 // PipeTo with writev writer
 async function testPipeToWithWritevWriter() {
   const allChunks = [];
@@ -301,6 +326,8 @@ Promise.all([
   testPipeToWithSignal(),
   testPipeToWithTransforms(),
   testPipeToSyncWithTransforms(),
+  testPipeToWriterTransformMethodIgnored(),
+  testPipeToSyncWriterTransformMethodIgnored(),
   testPipeToWithWritevWriter(),
   testPipeToSyncFallback(),
   testPipeToPreventFail(),