[michaelsbradley]

You might find pipe in IxJS worth a look:

https://github.com/ReactiveX/IxJS/blob/master/src/asyncitera...

https://github.com/ReactiveX/IxJS/blob/master/src/iterable/i...