RxPY v5

[dbrattli]

RxPY v5: Fluent Method Chaining Support

Summary

This release introduces fluent method chaining to RxPY while maintaining full backward compatibility with the existing pipe-based functional style. Both styles now work seamlessly together.

What's New

Dual Syntax Support - Use operators as methods OR functions:

Fluent style (NEW)

(
    rx.of(1, 2, 3, 4, 5)
    .map(lambda x: x * 2)
    .filter(lambda x: x > 5)
    .take(3)
    .subscribe(print)
)

Functional style (still works)

rx.of(1, 2, 3, 4, 5).pipe(
    ops.map(lambda x: x * 2),
    ops.filter(lambda x: x > 5),
    ops.take(3)
).subscribe(print)

Mix both styles freely

source.map(lambda x: x * 2).pipe(
    ops.filter(lambda x: x > 5),
    ops.take(3)
)

Current Progress

• 90 operators implemented with method chaining support (54.9% complete)
• Zero breaking changes - all existing code continues to work
• Full type safety - strict pyright/mypy compliance
• Complete documentation - all methods include both styles in examples
• 1401 tests passing - comprehensive test coverage

Implementation Details

###Architecture:

Mixin-based organization (11 category-focused mixins)
Observable inherits all operator methods via multiple inheritance
Each method delegates to the corresponding operator function via pipe()

Categories Completed:

✅ Transformation (map, flat_map, scan, starmap, etc.)
✅ Filtering (filter, take, skip, distinct, etc.)
✅ Mathematical (count, sum, average, min, max)
✅ Conditional (take_while, skip_until, default_if_empty)
✅ Combination (merge, zip, combine_latest, with_latest_from)
✅ Error Handling (catch, retry, on_error_resume_next)
✅ Utility (do_action, delay, timestamp, observe_on)
✅ Time-based (sample, debounce, delay_subscription)
✅ Windowing & Buffering (buffer, window, group_by, all variants)
✅ Multicasting (share, publish, replay, multicast)
✅ Testing (all, some, is_empty, contains, sequence_equal)

Migration Guide

No migration needed! This is a pure feature addition. See docs/migration.rst for the new Migration v5 section with complete examples.

Breaking Changes

None - This release is 100% backward compatible. Minor Fix: Renamed internal ReplaySubject.window attribute to ReplaySubject._window to avoid naming conflict with the new window() method. This is a private implementation detail and should not affect user code.

[coveralls]

coverage: 93.425% (-0.04%) from 93.462%
when pulling 27bb330 on fluent-style
into a999275 on master.