RxJS-Streams

Adds functions to work with Streams with Rx.

Currently only fromReadStream is implemented. Usage:

import import { fromReadStream } from 'rxjs-streams';
 
const stream = createStremSomehow();
const observable = fromReadStream(stream);
observable.pipe(
  //... do stuff
);