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