maxcon
TypeScript icon, indicating that this package has built-in type declarations

2.4.0 • Public • Published

MAXCON

Run series of operations in a dependency driven, maximumly concurrent way.

npm version

Install

npm install --save maxcon

Usage

const Rx = require('rx');
 
const config = {
  a: {
    process: () => Rx.Observable.just('value a'),
  },
  b: {
    process: () => Rx.Observable.just('value b'),
  },
  c: {
    // `process` will be called with observables returned from task a and b
    dependsOn: ['a', 'b'],
    process: (upstream) => Rx.Observable.zip(upstream.a, upstream.b),
  },
};
 
const maxcon = new Maxcon(config);
 
// Calling `connect` will do three things:
// 1. invoke all `process` functions once.
// 2. invoke `share` method of observables returned from `process` functions.
// 3. observables that are not depended on (no downstream) will be merged
//    and converted to a ConnectableObservable (by calling `publish`) and
//    then connected (by calling `connect`).
maxcon.connect();

Readme

Keywords

Package Sidebar

Install

npm i maxcon

Weekly Downloads

1

Version

2.4.0

License

MIT

Last publish

Collaborators

  • daiweilu