/** * Unwraps `Exit` values and flatten chunks that also signify end-of-stream * by failing with `None`. * * @tsplus getter effect/core/stream/Stream flattenTake */ export function flattenTake( self: Stream> ): Stream { return (self .map((take) => take.exit as Exit, A>) .flattenExitMaybe as Stream>) .unchunks }