@nitedani/rxjs-stream

Currently this package has one function:<br> `fromReadStream<T>(readStream:stream.Readable): Observable<T>` <br> <br> `fromReadStream` creates an rxjs observable from a node readstream with backpressure support. <br> How it works: the underlying read

0.0.9 • Published 4 years ago