test: add tests for the exclusive() operator

[github-actions]

🤖 This PR was created by Repo Assist, an automated AI assistant.

Summary

Adds 10 TestScheduler-based tests for the exclusive() operator in tests/test_observable/test_exclusive.py.

exclusive() subscribes to each inner observable emitted by the outer source one at a time, silently dropping any inner observable that arrives while another is still active. This operator had no tests at all.

Tests added

Test	What it verifies
test_exclusive_never	never-observable outer → no messages
test_exclusive_empty_outer	empty outer → on_completed passes through
test_exclusive_single_inner_completes	single inner, all items forwarded
test_exclusive_drops_concurrent_inner	inner2 arriving while inner1 is active is silently dropped
test_exclusive_sequential_inners	inner2 arriving after inner1 completes is subscribed normally
test_exclusive_multiple_concurrent_drops	multiple concurrent arrivals are all dropped
test_exclusive_outer_error	error on outer propagates immediately
test_exclusive_inner_error	error on inner propagates immediately
test_exclusive_completes_when_outer_and_inner_done	completion deferred until both outer and active inner finish
test_exclusive_disposed	early disposal stops subscription correctly

Checklist

• All 10 new tests pass (uv run pytest tests/test_observable/test_exclusive.py)
• Full suite still passes (uv run pytest — 1491 passed)
• ruff check and ruff format --check pass
• CI validates via uv run pytest

Generated by Repo Assist

Note

🔒 Integrity filter blocked 76 items

The following items were blocked because they don't meet the GitHub integrity level.

• using timeout with GroupedObservable leads to an index shift #225 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• Sort hot observable between (slow) scan executions #237 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• Observable interval appears to leak #259 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• Example noteboks are out of date #265 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• Proposal for a subscribe scheduler #309 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• Convert async iterator to Obervable #422 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• Weird interaction between group_by and to_iterable? #467 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• Q: how to use scheduler with subject for concurrency? #528 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• When using from_iterable with a generator the generator might not be closed #546 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• Kivy scheduler is not in the library #560 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• Exceptions get silently dropped when using from_iterable() #563 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• rx.timer works only with naive date object #574 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• Adding Initial Value to Subject using start_with doesn't work for subscribe with AsyncIOScheduler #579 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• concat_map implementation or equivalent? #581 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• Memory usage increases with subject and threadpool scheduler #582 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• Connectable observable sends events multiple times #591 list_issues: has lower integrity than agent requires. The agent cannot read data with integrity below "approved".
• ... and 60 more items

To allow these resources, lower min-integrity in your GitHub frontmatter:

tools:
  github:
    min-integrity: approved  # merged | approved | unapproved | none

Generated by Repo Assist · ● 6.8M · ◷

[coveralls]

coverage: 93.559% (+0.04%) from 93.524% — repo-assist/test-exclusive-operator-2026-05-02-2b47081797817f4d into master