`Stream.groupWithin` swallowing errors when using `EitherT` effect.
Nobody has claimed this yet.
- Dominant language
- Scala
- Stars
- 2.5k
- Forks
- 636
- Avg merge
- 2d 4h
- Merged PRs (30d)
- 7
Description
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
Contributor guide
First steps
- Read the whole issue, then the project's contributing guide.
- Comment on the issue to say you are picking it up — it saves two people doing the same work.
- Fork the repository and make your change on a branch.
- Open a pull request that references the issue number.
Research direction
Start with the linked Scastie minimal example and trace Stream.groupWithin with an EitherT effect, comparing it with IO.raiseError. Done means the left is propagated as a failed stream rather than returning the preceding elements as a successful completion, with regression coverage for both cases.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- scala
- Domain
- stream-processing
- Issue type
- Bug
- Difficulty
- 3/5
- Estimated time
- 1-2 days
- Activity status
- Stale
- Clarity
- Mostly clear
- Newbie friendliness
- 45/100