v1.0.0
call an async function for each data event into through stream. manage concurrency as back pressure
Source code on GitHub