Skip to content

Commit 8b59bc7

Browse files
github-actions[bot]Copilotclaude
authored
chore: fix typing exports, add docstring to on_error_resume_next (#763)
- Add Action and StartableFactory to reactivex.typing.__all__ so they are part of the explicit public API surface (they were defined but omitted from __all__). - Add missing docstring to on_error_resume_next inner function in reactivex/operators/_onerrorresumenext.py. 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: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
1 parent 5268dde commit 8b59bc7

3 files changed

Lines changed: 15 additions & 0 deletions

File tree

changes.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,9 @@
22

33
## Unreleased
44

5+
- Typing: Added `Action` and `StartableFactory` to `reactivex.typing.__all__`,
6+
making them part of the explicit public API surface.
7+
- Docs: Added missing docstring to `on_error_resume_next` operator.
58
- Operators: Fixed scheduler forwarding in `pairwise`, `to_marbles`, and
69
`delay_with_mapper` (subscription-delay path). These operators now pass the
710
`scheduler` argument through to `source.subscribe(...)` and, in the case of

reactivex/operators/_onerrorresumenext.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,16 @@ def on_error_resume_next_(
1111
second: Observable[_T],
1212
) -> Callable[[Observable[_T]], Observable[_T]]:
1313
def on_error_resume_next(source: Observable[_T]) -> Observable[_T]:
14+
"""Continues an observable sequence that is terminated normally or
15+
by an exception with the next observable sequence.
16+
17+
Args:
18+
source: First observable sequence.
19+
20+
Returns:
21+
An observable sequence that concatenates the source and second
22+
sequences, even if the source sequence terminates exceptionally.
23+
"""
1424
return reactivex.on_error_resume_next(source, second)
1525

1626
return on_error_resume_next

reactivex/typing.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,6 +49,7 @@
4949
"Accumulator",
5050
"AbsoluteTime",
5151
"AbsoluteOrRelativeTime",
52+
"Action",
5253
"Comparer",
5354
"Mapper",
5455
"MapperIndexed",
@@ -63,6 +64,7 @@
6364
"ScheduledSingleOrPeriodicAction",
6465
"ScheduledAction",
6566
"Startable",
67+
"StartableFactory",
6668
"StartableTarget",
6769
"Subscription",
6870
]

0 commit comments

Comments
 (0)