ストリームから一連の入力を読み取り、入力ごとに HTTP GET 要求を実行します。一度に作成する接続が多すぎるのを避けるために、async.queueを使用してこれらの入力をキューに入れています。
すべての入力が読み取らendれた後 (ストリームに出力された後)、以前の結果を収集して概要を生成したいと思います。
私は現在queue.drain、この目的のために使用しています。ただしqueue.drain、プロセスが入力時にブロックされる可能性があり、これが発生するとキューが空になるため、私の場合は複数回呼び出される可能性があります。
queue.drainそれで、ストリームを扱うときに一度だけ呼び出されることを保証する非同期ライブラリに何かがありますか? この機能が実現できる限り、別の制御フローに切り替えてもかまいません。