Streams & Pipelines

When to use

• You’re building data pipelines with batching/backpressure
• You need controlled concurrency per element
• You must process large inputs with constant memory

Create

const s = Stream.fromIterable(items)