Build a limited concurrency through2 stream from an async function