Set up a queue of Observables with RxJS

Queueing with RxJS

stream$.flatMap(array => {
	let observablesArray = array.map(arrayItem => {
		// map over array returning observables - this can be nested and flattened
		return Rx.Observable.fromPromise(promiseFunction(arrayItem))
			// whatever other rx-y things you need to do
			.retry(2)
			// what do we really want to do with these errors
			.catch(e => {
				return Rx.Observable.of({
					errorStatus: true,
					error: e
				});
			});
	});
	// zip will return when all promises return - order not guaranteed
	// use concat instead of zip if order matters
	return Rx.Observable.zip.apply(null, observablesArray);
}).subscribe(...);