parallel-transform-web
Parallel transform for web streams. Zero dependencies.
Note: does not preserve ordering.
Install
npm i parallel-transform-web
Usage
import { Parallel } from 'parallel-transform-web'
// a stream that yields random numbers, forever!
const randomNumbers = new ReadableStream({ pull: controller => controller.enqueue(Math.random() * 10) })
// run up to 10 transforms concurrently
const concurrency = 10
// identity transform that adds a short delay
const transformer = n => new Promise(resolve => setTimeout(() => resolve(n), n))
// parallelized transform stream
const delayer = new Parallel(concurrency, transformer)
// writable stream that just logs whatever is written to it
const logger = new WritableStream({ write: n => console.log(n) })
await 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
