zen-push

A push stream observable class. (Sometimes called a Subject in Rx-speak.)

Install

``sh
npm install zen-push
`

Usage

`js
import PushStream from 'zen-push';

let pushStream = new PushStream();
pushStream.observable.subscribe(value => console.log(Hello ${value}!));
pushStream.next('World'); // 'Hello World!'
`

API

$3

`js
let pushStream = new PushStream();
`

Creates a new PushStream object.

$3

`js
pushStream.observable.subscribe(value => console.log(Hello ${value}!));
`

The instance of Observable used to listen to elements in the push stream.

$3

`js
pushStream.next('World');
`

Sends the next stream value to all observers.

$3

`js
pushStream.error(new Error('The planet as been destroyed'));
`

Sends an error to all observers. Calling this method terminates the stream.

$3

`js
pushStream.complete();
`

Sends a signal to all observers that the stream is finished. Calling this method terminates the stream.

$3

`js
let multicastObservable = PushStream.multicast(observable);
multicastObservable.subscribe(console.log);
multicastObservable.subscribe(console.log);
`

Uses a PushStream` to send an observable's values to multiple subscribers.