Асинхронная карта с Highland.js

Question

У меня есть поток Highland, который периодически получает данные с сервера. Мне нужно сделать поиск базы данных внутри карты. Я не могу найти упоминаний о том, чтобы сделать что-то асинхронное в каком-либо из трансформаторов Хайленда.

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);
});

Скрипка здесь

Или с .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);
});

Скрипка здесь