Skip to content

fix: Fix recoverWith with add missing attempt back.#2712

Merged
He-Pin merged 3 commits intomainfrom
fixRecover
Mar 4, 2026
Merged

fix: Fix recoverWith with add missing attempt back.#2712
He-Pin merged 3 commits intomainfrom
fixRecover

Conversation

@He-Pin
Copy link
Member

@He-Pin He-Pin commented Mar 4, 2026

Motivation:
It was reverted and there is a bug in that code.

refs: #2620
refs: #2694

@He-Pin He-Pin added the t:stream Pekko Streams label Mar 4, 2026
case singleSource: SingleSource[T @unchecked] => emit(out, singleSource.elem, () => completeStage())
case failed: FailedSource[T @unchecked] => onFailure(failed.failure)
case failed: FailedSource[T @unchecked] =>
attempt += 1
Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

missed the attempt += 1

@He-Pin He-Pin requested a review from pjfanning March 4, 2026 18:13
@pjfanning pjfanning removed their request for review March 4, 2026 20:05
Copy link
Member

@pjfanning pjfanning left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

lgtm

I tried this on my laptop with the pekko-http tests that broke before and they work with this version.

I would appreciate if we just keep this as 2.0.0 change because I don't want to take any more risks with the 1.x releases.

@He-Pin
Copy link
Member Author

He-Pin commented Mar 4, 2026

Yeah,let's just keep it in 2.0.0, thanks for the testing

@He-Pin He-Pin merged commit 2939de0 into main Mar 4, 2026
9 checks passed
@He-Pin He-Pin deleted the fixRecover branch March 4, 2026 20:12
@He-Pin
Copy link
Member Author

He-Pin commented Mar 4, 2026

It was spring festival, sorry for the delay

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

t:stream Pekko Streams

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants