fs2
fs2 copied to clipboard
`Stream.groupWithin` swallowing errors when using `EitherT` effect.
When calling groupWithin on a Stream[EitherT[F, A, *], B] The stream halts on the first left, but completes with a success of the elements up to the left. This behavior is different than the case with IO.raiseError: In this case the stream completes as a failure as expected.
Scastie showing minimal example: https://scastie.scala-lang.org/9jBkYj3QSZqKFvN5uPSVtw