use es.through instaed of es.map in the apiStream in order to make an api call in parallel