RxJS相当のAsync.js mapLimit

Question

Async.js mapLimitおよびそのファミリの<name>Limitは基本的にセマフォのように機能します。余分な着信タスクがキューに追加されている間に限られた数のタスクを同時に実行できます。キューは（コールドコネクト？）プロデューサになります。タスクランナーは、スポットが利用可能になるとすぐに（そのタスクの1つが終了する）、アイテムをキューから排出する。

このように、限られた数の並行タスクが常にアクティブです。

RxJSで同様の機能を実現するにはどうすればよいですか？

Answer 1

deferとflatMapWithMaxConcurrentの組み合わせは、それを行うにはRxJsの方法です：

// returns a promise 
function runSomeJob(input) { ... } 

function runSomeJobObservable(input) { 
    return Rx.Observable.defer(function() { 
     return runSomeJob(input); 
    }); 
} 

var inputStream = // some Rx.Observable 

// only allow 5 jobs to run concurrently 
var outputStream = inputStream 
    .flatMapWithMaxConcurrent(5, runSomeJobObservable); 

ouputStream.subscribe(...);