Pure-stream NPM

pure-stream

Collection of utilities for working with object streams

About

This library uses a new class PureStream to implement object streams in an easy and logical way.

PureStreams are ended when an error occurs
pipe-ing propagates errors from source to destination(s)
No events. Data is collected with each and ended with done

PureStreams are lazy, they won't begin reading data until .done is called.

Install

$ npm install pure-stream
# or
$ yarn add pure-stream

Quick-Start

import {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');
});