Collection of utilities for working with object streams
This library uses a new class PureStream to implement object streams in an easy and logical way.
- PureStreams are
endedwhen an error occurs pipe-ing propagates errors from source to destination(s)- No events. Data is collected with
eachand ended withdone
PureStreams are lazy, they won't begin reading data until .done is called.
$ npm install pure-stream
# or
$ yarn add pure-streamimport {from, map} from 'pure-stream';
from([1, 2, 3])
.pipe(map((value) => value * 2))
.each((value) => {
console.log(value);
// Output:
// 2
// 4
// 6
})
.done((err) => {
if (err) console.log('Error:', err);
else console.log('Success');
});