rxdable
Utility lib to work with Node.js streams and Rx.js.
- Node.js >= 10.x
- Rx.js 6.x
- Zero dependencies
- TypeScript support
Observable to Readable stream
const getStreamByObservable = const readableStream =
Readable stream to Observable
const createReadStream = const subscribeToStream = const Observable = { return { return }}
Readable stream to Observable (faster way)
const getObservableByStream = const observable =
WARNING: This function will create an Observable ables to be subscribed just one time.
Operator to Transform stream
const count = const getStreamByOperator = const countStream =
Multiple operators are supported:
const map = const getStreamByOperator = const firstUppercasedLetterStream =
Passthrough (no operators) is supported:
const getStreamByOperator = const passthroughStream =
Writable/Duplex/Transform stream to operator
const createWriteStream = const pipeObservableToStream = const Observable = { return { return { return } }}
Writable/Duplex/Transform stream to operator (faster way)
const getOperatorByStream = const operator =
WARNING: This function will create an Operator ables to be used just one time.