/** * Effectfully maps each element to an Collection, and flattens the Collections * into the output of this stream. * * @tsplus static effect/core/stream/Stream.Aspects mapConcatEffect * @tsplus pipeable effect/core/stream/Stream mapConcatEffect */ export function mapConcatEffect( f: (a: A) => Effect> ) { return (self: Stream): Stream => self.mapEffect((a) => f(a).map(Chunk.from)).mapConcat(identity) }