Async Map with Highland.js

Question

我有一個定期從服務器獲取數據的高地流。我需要在地圖中進行數據庫查找。我找不到在高地的任何變壓器上做任何異步操作的情況。

Answer 1

您可以使用consume以異步方式處理流。

_([1, 2, 3, 4]).consume(function(err, item, push, next) { 
    // Do fancy async thing 
    setImmediate(function() { 
    // Push the number onto the new stream 
    push(null, item); 

    // Consume the next item 
    next(); 
    }); 
})).toArray(function(items) { 
    console.log(items); // [1, 2, 3, 4] 
}); 

Answer 2

使用.map後，您可以使用一個.sequence爲：

var delay = _.wrapCallback(function delay(num, cb){ 
    setTimeout(function(){ cb(null, num+1); }, 1000); 
}); 

_([1,2,3,4,5]).map(function(num){ 
    return delay(num); 
}).sequence().toArray(function(arr){ // runs one by one here 
    console.log("Got xs!", arr); 
}); 

Fiddle here。

並行

或用.parallel：

var delay = _.wrapCallback(function delay(num, cb){ 
    setTimeout(function(){ cb(null, num+1); }, 1000); 
}); 

_([1,2,3,4,5]).map(function(num){ 
    console.log("got here", num); 
    return delay(num); 
}).parallel(10).toArray(function(arr){ // 10 at a time 
    console.log("Got xs!", arr); 
}); 

Fiddle here