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

2 participants