A Stream transformer for performing flat mapping on async streams