parallel-transform-web

Parallel transform for web streams. Zero dependencies.

Note: does not preserve ordering.

Install

1npm i parallel-transform-web

Usage

1import { Parallel } from 'parallel-transform-web'
2
3// a stream that yields random numbers, forever!
4const randomNumbers = new ReadableStream({ pull: controller => controller.enqueue(Math.random() * 10) })
5// run up to 10 transforms concurrently
6const concurrency = 10
7// identity transform that adds a short delay
8const transformer = n => new Promise(resolve => setTimeout(() => resolve(n), n))
9// parallelized transform stream
10const delayer = new Parallel(concurrency, transformer)
11// writable stream that just logs whatever is written to it
12const logger = new WritableStream({ write: n => console.log(n) })
13
14await randomNumbers.pipeThrough(delayer).pipeTo(logger)

Contributing

Feel free to join in. All welcome. Please open an issue!

License

Dual-licensed under MIT + Apache 2.0