Metadata-Version: 2.4
Name: rx-rust
Version: 0.1.0
Summary: Rx-Rust — Reactive Extensions for Python. A high-performance reactive programming library with Observable/Observer/Subject/Scheduler support. (Pure-Python implementation: no Rust toolchain required to install.)
Author-email: Victor <victor@rx-rust.dev>
License: MIT
Project-URL: Homepage, https://gitcode.com/VictorTop/Rx-Rust
Project-URL: Repository, https://gitcode.com/VictorTop/Rx-Rust.git
Project-URL: Issues, https://gitcode.com/VictorTop/Rx-Rust/issues
Keywords: reactive,rx,observable,streams,async,event-driven,functional-programming,publisher-subscriber,subject,scheduler,rx-rust,rxpy
Classifier: Development Status :: 3 - Alpha
Classifier: Intended Audience :: Developers
Classifier: Intended Audience :: Science/Research
Classifier: License :: OSI Approved :: MIT License
Classifier: Operating System :: OS Independent
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.8
Classifier: Programming Language :: Python :: 3.9
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Programming Language :: Python :: 3.13
Classifier: Topic :: Software Development :: Libraries :: Python Modules
Classifier: Topic :: Software Development :: Libraries
Requires-Python: >=3.8
Description-Content-Type: text/markdown

# rx-rust — Reactive Extensions for Python

一个高性能的响应式编程库，提供 Observable / Observer / Subject / Scheduler 支持。

## 快速开始

```bash
pip install rx-rust
```

```python
import rx_rust

result = []
rx_rust.Observable.from_iter([1, 2, 3, 4, 5]) \
    .filter(lambda x: x % 2 == 0) \
    .map(lambda x: x * 10) \
    .subscribe(on_next=lambda v: result.append(v))

print(result)  # [20, 40]
```

## 核心对象

- **Observable** — 可观察序列（`from_iter`, `of`, `range`, `repeat`, `empty`, `never`）
- **操作符** — `map`, `filter`, `take`, `skip`, `reduce`, `scan`, `flat_map`, `merge`, `concat`, `start_with`, `default_if_empty`, `contains`, `all`, `sum`, `count`, `do_on_next`
- **Subject** — `PublishSubject`, `BehaviorSubject`, `ReplaySubject`
- **Subscription** — 订阅管理，支持 `dispose()` 和 `is_disposed()`
- **Scheduler** — `CurrentThreadScheduler`, `ThreadPoolScheduler`, `AsyncScheduler`, `ImmediateScheduler`

## License

MIT
