refactored concurrently.flatMap to mergeFlatten. added MergeFlattenTest