Node.jsのasync.queueでasync/awaitを使う方法

Node.jsのasyncモジュールにqueueというメソッドがあり、簡単にqueueを使った直列処理を行うことができる。

caolan/async: Async utilities for node and the browser

実際に処理するものの定義は下記のようにcallbackを実行して完了を知らせる。

var q = async.queue(function(task, callback) {
  console.log('hello ' + task.name);
  callback();
}, 2);

このクロージャはasync/awaitを使うことも可能。ただ、その場合には引数のcallbackがなくなるので呼ぶとエラーになる。

結局、Promiseになるためいちいちcallbackを呼ぶ必要がなくなるということっぽい。なので先程の例だと下記のようになる。

var q = async.queue(async function(task) {
  console.log('hello ' + task.name);
  const err = getError(task)
  if (err) {
    return err
  }
  // 成功の場合はreturnも不要
}, 2);