Skip to content

Conversation

@mrsants
Copy link

@mrsants mrsants commented Oct 15, 2025

  • Removed two unnecessary nested loops, reducing complexity and improving performance
  • Replaced mutable list flags with nonlocal variables for cleaner state handling
  • Added fallback threading.RLock() when parent.lock is not present
  • Improved type hints using generics (TypeVar, Tuple[T, ...])
  • Added input validation to raise ValueError when no sources are provided
  • Expanded and standardized docstring (PEP 257 + NumPy style)

…and improving docs

- Removed two unnecessary nested loops, reducing complexity and improving performance
- Replaced mutable list flags with `nonlocal` variables for cleaner state handling
- Added fallback `threading.RLock()` when `parent.lock` is not present
- Improved type hints using generics (`TypeVar`, `Tuple[T, ...]`)
- Added input validation to raise `ValueError` when no sources are provided
- Expanded and standardized docstring (PEP 257 + NumPy style)
@coveralls
Copy link

Coverage Status

coverage: 93.482% (+0.001%) from 93.481%
when pulling 84175cf on mrsants:improvement/combine-latest-thread-safety
into 7747af3 on ReactiveX:master.

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

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants