rxRust

KO | EN

gitlite — search

#javascript #react #ai #typescript #golang #rust #linux #java #windows #vue #awesome-list #pytorch #security #mcp

(★ 1,105)

Zero-cost & Type-safe Reactive Extensions for Rust. Supports both high-performance single-threaded (Local) and thread-safe (Shared) contexts. WASM & Tokio ready.

File Explorer

Download Latest Version (.zip)

- config.toml
- - deploy-docs.yml
  - grcov.yml
  - main.yml
- grcov.config.yml
- custom_scheduler.rs
- - architecture_deep_dive.md
  - architecture_diagram.jpeg
  - custom_operators.md
  - custom_scheduling.md
  - nightly.md
- - auto_save.md
  - gui.md
  - heartbeat.md
  - state_store.md
  - wasm.md
- - context.md
  - scheduler.md
  - type_erasure.md
- - version-picker.js
- advanced.md
- async_interop.md
- book.toml
- contributing.md
- cookbook.md
- core_concepts.md
- getting_started.md
- introduction.md
- operators.md
- SUMMARY.md
- - lib.rs
- Cargo.toml
- - boxed.rs
  - connectable.rs
  - create.rs
  - defer.rs
  - from_fn.rs
  - from_future.rs
  - from_iter.rs
  - from_stream.rs
  - interval.rs
  - of.rs
  - timer.rs
  - trivial.rs
- - aggregation_tests.rs
  - average.rs
  - box_it.rs
  - buffer.rs
  - buffer_count.rs
  - buffer_time.rs
  - collect.rs
  - combine_latest.rs
  - contains.rs
  - debounce.rs
  - default_if_empty.rs
  - delay.rs
  - distinct.rs
  - distinct_until_changed.rs
  - filter.rs
  - filter_map.rs
  - finalize.rs
  - flat_map.rs
  - group_by.rs
  - into_future.rs
  - into_stream.rs
  - last.rs
  - lifecycle.rs
  - map.rs
  - map_err.rs
  - map_to.rs
  - merge.rs
  - merge_all.rs
  - observe_on.rs
  - pairwise.rs
  - reduce.rs
  - ref_count.rs
  - retry.rs
  - sample.rs
  - scan.rs
  - scan_map.rs
  - skip.rs
  - skip_last.rs
  - skip_until.rs
  - skip_while.rs
  - start_with.rs
  - subscribe_on.rs
  - switch_map.rs
  - take.rs
  - take_last.rs
  - take_until.rs
  - take_while.rs
  - tap.rs
  - throttle.rs
  - with_latest_from.rs
  - zip.rs
- - test_scheduler.rs
- - behavior_subject.rs
  - subject_core.rs
  - subject_subscription.rs
  - subscribers.rs
- - boxed.rs
  - dynamic.rs
  - either.rs
  - source_with_dynamic.rs
  - source_with_handle.rs
  - tuple.rs
- context.rs
- factory.rs
- lib.rs
- observable.rs
- observer.rs
- ops.rs
- prelude.rs
- rc.rs
- scheduler.rs
- subject.rs
- subscription.rs
- v1_integration.rs
.gitignore
Cargo.toml
CHANGELOG.md
LICENSE
missing_features.md
README.md
rustfmt.toml

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# rxRust: Reactive Extensions for Rust

[![](https://docs.rs/rxrust/badge.svg)](https://docs.rs/rxrust/)
[![Documentation](https://img.shields.io/badge/docs-latest-blue.svg)](https://rxrust.github.io/rxRust/)
[![codecov](https://codecov.io/gh/rxRust/rxRust/branch/master/graph/badge.svg)](https://codecov.io/gh/rxRust/rxRust)
[![CI](https://github.com/rxRust/rxRust/actions/workflows/main.yml/badge.svg)](https://github.com/rxRust/rxRust/actions/workflows/main.yml)
[![](https://img.shields.io/crates/v/rxrust.svg)](https://crates.io/crates/rxrust)
[![](https://img.shields.io/crates/d/rxrust.svg)](https://crates.io/crates/rxrust)

**rxRust** is a zero-cost, type-safe Rust implementation of [Reactive Extensions](http://reactivex.io/). It brings **Functional Reactive Programming (FRP)** to Rust, enabling a declarative coding style for handling asynchronous events, stream processing, and concurrency.

It leverages Rust's ownership system to ensure memory safety and efficient resource usage, making it ideal for build robust event-driven applications.

## 🚀 Key Features

*   **Zero-Cost Abstractions**: Heavily relies on generic specialization and monomorphization to compile down to efficient code, ensuring minimal overhead for your asynchronous streams.
*   **Pay-for-what-you-need**: Choose the right tool for the job. Use `Local` (Rc/RefCell) for single-threaded performance without locking overhead, or `Shared` (Arc/Mutex) when thread synchronization is actually required.
*   **Unified Logic, Adaptive Context**: Write your stream logic once. The same operator chains adapt seamlessly to different environments based on the context they run in.
*   **Interoperability**: Seamlessly integrates with Rust `Future`s, streams, and `async/await`.
*   **Wasm Support**: Works out of the box on WebAssembly.

## 📦 Installation

Add this to your `Cargo.toml`:

```toml
[dependencies]
rxrust = "1.0.0-rc.0"
```

## ⚡ Quick Start

rxRust v1.0 unifies its **API and implementation logic**, while the **Context** (environment) provides the most suitable resource types at compile-time. The API remains consistent regardless of whether you are in a single-threaded or multi-threaded environment.

```rust
use rxrust::prelude::*;

fn main() {
    // 🟢 Local Context: No locks, high performance for single thread
    Local::from_iter(0..10)
        .filter(|v| v % 2 == 0)
        .subscribe(|v| println!("Local Even: {}", v));

// 🔵 Shared Context: Thread-safe, ready for concurrency
    Shared::from_iter(0..10)
        .map(|v| v * 2)
        .subscribe(|v| println!("Shared Doubled: {}", v));
}
```

## 🎯 Core Concepts

### 1. Select Your Context

The **Context** determines the execution strategy and memory management:

*   **`Local`**: **No Locking.** Uses `Rc` and `RefCell`. Ideal for UI threads, WASM, or single-threaded event loops. The compiler ensures these types don't leak across threads.
*   **`Shared`**: **Thread Safe.** Uses `Arc` and `Mutex`. Required when streams need to jump across threads or share state globally.

![rxRust Architecture - Local vs Shared Context](https://raw.githubusercontent.com/rxRust/rxRust/master/guide/advanced/architecture_diagram.jpeg)

### 2. Schedulers & Timing

Control *when* and *where* work happens using schedulers. By default, **rxRust** schedulers rely on `tokio`. You can also disable the default `scheduler` feature to implement a custom scheduler adapted to your own runtime.

```rust
use rxrust::prelude::*;

#[tokio::main(flavor = "local")]
async fn main() {
    // Emit a value after 100ms
    Local::timer(Duration::from_millis(100))
        .subscribe(|_| println!("Tick!"));

// Throttle a busy stream
    Local::interval(Duration::from_millis(10))
        .throttle_time(Duration::from_millis(100), ThrottleEdge::leading())
        .subscribe(|v| println!("Throttled: {}", v));
}
```

*Note: `Local` context schedulers require running within a `LocalSet` or a compatible `LocalRuntime`.*

### 3. Subjects (Multicasting)

Subjects allow you to multicast events to multiple subscribers. The `Subject` type automatically adapts its internal storage (`Rc<RefCell<...>>` vs `Arc<Mutex<...>>`) based on the context used to create it.

```rust
use rxrust::prelude::*;

// Created in a Local context, this Subject uses RefCell internally (no Mutex)
let mut subject = Local::subject();

subject.clone().subscribe(|v| println!("Observer A: {}", v));
subject.clone().subscribe(|v| println!("Observer B: {}", v));

subject.next(1);
subject.next(2);
```

## 📚 Documentation & Guide

For a deeper dive into core concepts, advanced architecture, and cookbooks, check out our **[rxRust Online Guide & Documentation](https://rxrust.github.io/rxRust/)**.

*   [Getting Started](guide/getting_started.md)
*   [Core Concepts](guide/core_concepts/context.md)
*   [Advanced Architecture](guide/advanced/architecture_deep_dive.md)

## 🌙 Nightly (Experimental)

rxRust targets **stable Rust** by default.

For advanced use-cases involving **lifetime-dependent mapped outputs** (e.g. `&'a mut T -> &'a U`), `map` provides an **experimental** implementation behind the Cargo feature `nightly`.

- Enable: `rxrust = { version = "1.0.0-rc.0", features = ["nightly"] }`
- Build with: `cargo +nightly test --features nightly`

Once the relevant language support (like GATs stabilization in specific patterns) is mature, we plan to expand this support.

## 🤝 Contributing

We welcome contributions! rxRust is a community-driven project.

*   Check out [Missing Features](missing_features.md) to see what operators are needed.
*   Look for "Good First Issue" tags on GitHub.
*   Improve documentation or add examples.

## 📄 License

MIT License

rxRust

File Explorer

Today's picks

Was this content helpful?

Recent Feedback

rxRust

File Explorer

Today's picks

Was this content helpful?

Recent Feedback

Download README