RxJS相當於Async.js mapLimit

Question

Async.js mapLimit及其系列的<name>Limit函數基本上像信號量一樣工作：在額外的傳入任務添加到隊列時，它們允許有限數量的任務同時運行。隊列變成（冷連接？）製作者。只要一個點可用（任務完成之一），任務運行者就會從隊列中排出一個項目。

這樣，有限數量的併發任務總是處於活動狀態。

如何在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(...);