All 10 Async Iterators & Streams questions
More in Async Iterators & Streams
What is the ReadableStream API used for? What does return() do on an async iterator? How do you convert a Node.js Readable stream into an async iterable? How do you run multiple async iterators concurrently and merge their results? Why might Promise.all() be the wrong tool when consuming many async iterators? How do you add a timeout to an async iterator's next() call?
Advertisement
JavaScript › Async Iterators & Streams

What's the difference between piping streams with pipeThrough() and pipeTo()?

Advanced

Answer

pipeTo() sends a ReadableStream's data into a WritableStream and returns a Promise that resolves when piping finishes. pipeThrough() sends data through a TransformStream (readable + writable in one) and returns a new ReadableStream you can keep chaining or reading further.
const transformed = response.body
  .pipeThrough(new TextDecoderStream())
  .pipeThrough(new SomeTransform());
await transformed.pipeTo(writableStream);
Real-world example Decoding, transforming, and compressing a file stream in one pipeline without buffering it all in memory.

Common follow-ups: How do you handle errors that occur mid-pipeline?

Networking: Fetch XHR WebSockets & CORS
All 10 Async Iterators & Streams questions