ReactiveX / RxPY / 24692625533

94%

push

github

fix(operators): reset retry budget per subscription to fix retry+repeat (#765)

The retry(n) generator was created once at observable creation time
and shared across all subscriptions. When combined with repeat(), the
retry pool was exhausted after n total subscriptions regardless of
errors, causing repeat() to resubscribe to an empty generator that
immediately completed.

Fix: create the generator inside the subscribe closure so each
subscription gets a fresh retry budget. This matches the expected
ReactiveX semantics where retry(n) means 'on error, resubscribe up
to n times per subscription'.

Closes #712

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>
Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>
Co-authored-by: Dag Brattli <dag@brattli.net>

13 of 13 new or added lines in 2 files covered. (100.0%)

25327 of 27087 relevant lines covered (93.5%)

0.94 hits per line