Вызов асинхронной функции из функционального map в JavaScript, как?

Question

[aleksandrvin]

Есть массив объектов. Хочется для него выполнить map делая HTTP запрос для каждого объекта и возвращая новый объект-ответ.


Как это сделать, если для HTTP запросов используется модуль http из Node.js, который выполняет вызов асинхронно?

Answer 1

[Сергей]

Если осилите статью, вопрос отпадет blog.jcoglan.com/2013/03/30/callbacks-are-imperative-promises-are-functional-nodes-biggest-missed-opportunity/

Comments

[aleksandrvin]

Огромное спасибо!

Это именно то, что я искал, но не думал, что futures сделаны и на JavaScript. Признаю шаблонность мышления за собой.

Но в общем — вам двойное спасибо, а всем остальным рекомендую осилить статью — за пару поездок в метро легко можно справиться ;)

Answer 2

[Yuri Shikanov]

Модуль async вам в помощь. А именно — метод map.

Answer 3

[lacki]

Можно вот так: github.com/caolan/async#eachseriesarr-iterator-callback

Comments

[aleksandrvin]

Оказалось близко, но map будет точнее: мне же результат надо собрать.

Answer 4

[aleksandrvin]

Не похоже, вкратце выглядит так:

inObjs.map(function /*ААА*/ (o) {
  var req = http.request(options, function (res) {
    var data = "";
    res.on('data', function (chunk) { data += chunk; };
    res.on('end', function () { /* Теперь надо объект data вернуть из лямбда-функции ААА */ ??? });
  });
  res.write(JSON.stringify(o));
  res.end();

  return /* Здесь надо дождаться того объекта data и вернуть его обратно в map */ ???
});

И параллельность или серийность работы map-а или eachSeries тут роли не играет.

Comments

[aleksandrvin]

Damn!

Ваш ответ был правильным, извиняюсь за свою недальновидность: покуда сам не придумал (мозги не повернулись в нужном направлении) — не увидел в ваших советах сути.

Answer 5

[aleksandrvin]

Вот, что в итоге получилось:

/**
 * Event-style map function with fun(e, consumer) as an element
 * transformation function that does not return modified object
 * but produce it to the ''consumer'' function instead.
 *
 * Result of the evmap-transformed objects will be transfered in
 * the ''callback'' call eventually.
 *
 * Main use is for maps with asynchronous transformation functions!
 */
function evmap(list, fun, callback) {
    function evmap(acc, list, fun) {
        if (list && 0 < list.length) {
            fun(list.shift(),
                function (result) {
                    acc.unshift(result);
                    evmap(acc, list, fun);
                });
        }
        else {
            callback(acc.reverse());
        }
    }
    evmap([], list, fun);
}

//// unit tests
exports.evmap_array = {
    'list': function (test) {
        evmap([1,2,3],
              function (e, c) { c(e + 10); },
              function (result) {
                  test.deepEqual(result, [11, 12, 13]);
                  test.done();
              });
    }
};

Comments

[aleksandrvin]

LOL!

Получилось идентично map.