ReactiveX / RxPY / 24588449860

94%

push

github

[Repo Assist] fix(operators): forward scheduler in pairwise, to_marbles, delay_with_mapper (#757)

* fix(operators): forward scheduler in pairwise, to_marbles, delay_with_mapper

Three operators were subscribing to their source without forwarding the
scheduler received at subscription time, breaking scheduler propagation
for downstream operators.

* _pairwise.py: add scheduler=scheduler to source.subscribe()
* _tomarbles.py: add scheduler=scheduler to source.subscribe()
* _delaywithmapper.py: add scheduler=scheduler to sub_delay.subscribe()
  in the subscription-delay path (the main source path was already fixed)

The other operators originally listed in issue #480 (delay_with_mapper
main path, throttle_first, timeout_with_mapper) were already forwarding
the scheduler correctly.

Closes #480 (partial)

Co-authored-by: Copilot <223556219+Copilot@users.noreply.github.com>

* test(operators): add regression tests for scheduler propagation

Cover pairwise, to_marbles, and delay_with_mapper (subscription-delay
path): each test installs a source whose subscribe captures the
scheduler it received, pipes through the operator, subscribes with a
known scheduler, and asserts the captured scheduler matches. Verified
to fail on the pre-fix code.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

---------

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>
Co-authored-by: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

48 of 49 new or added lines in 5 files covered. (97.96%)

25206 of 26973 relevant lines covered (93.45%)

0.93 hits per line