Questions on Enhancing and Handling Errors in `Stream` Operations

two questions about Stream
1. we have Stream.filterMapEffect((a: A) => Option<Effect<B>>, would it make sense to have a Stream.filterMapEffect2((a: A) => Effect<Option<B>>) (name tbd)? otherwise you'll have to Stream.mapEffect(x => f(x)) |> Stream.filterMap(identity)
2. the semantics of stream seem like once it gets an error, the stream aborts. i find myself doing mapEffect(Effect.option(effect)) |> filterMap(identity), i wonder if that's the blessed way? maybe i just misuse streams? maybe i need to read docs?
love you all
Was this page helpful?