A lightweight library that operates on rxjs to execute a stream chains sequentially or in parallel with defined limit of simultaneous executions.
npm install @ivlasov/rxsyncA lightweight library that operates on rxjs to execute a stream chains sequentially or in parallel with defined limit of simultaneous executions.
Async/waterfall, async/parallel or async/eachLimit is very easy and useful libraries but for callbacks. This library uses RxJs and allows to make a stream chains in nice format
npm install @ivlasov/rxsync --save
javascript
const rxsync = require('@ivlasov/rxsync');rxsync.waterfall([
()=>{
return Observable.of(1);
},
(res)=>{
return Observable.of(res+1);
},
(res)=>{
return Observable.of(res+1);
}
]).subscribe(res=>{
console.log(res) //3
});
`$3
Creates a stream with parallel execution of input streams. Returns an object with results of all streams executions, when the last one is finishedjavascript
const rxsync = require('@ivlasov/rxsync');rxsync.parallel({
one: ()=>{
return Observable.of(1);
},
two: ()=>{
return Observable.of(2);
},
three: ()=>{
return Observable.of(3);
}
}).subscribe(res=>{
console.log(res);
/*
{
one: 1,
two: 2,
three: 3
}
*/
});
`$3
Creates a stream with parallel execution of array of streams and limitation of simultaneous executionsjavascript
const rxsync = require('@ivlasov/rxsync');
const array=[1,2,3,4,5,6,7,8,9,10]//rxsync.eachLimit(streams, limit);
rxsync.eachLimit(array.map(item=>{
return Observable.of(item);
}), 5).subscribe(res=>{
console.log(res); //[1,2,3,4,5,6,7,8,9,10]
});
``