rxrust 1.0.0-rc.4

A Rust implementation of Reactive Extensions.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165

#![cfg_attr(feature = "nightly", feature(fn_traits, unboxed_closures))]
// The nightly-only `fn_traits` support is intentionally kept as the primary
// path for lifetime-dependent `map` outputs. Replacing it wholesale with a
// library-defined callable trait degrades type inference for ordinary closures,
// most visibly at `subscribe` call sites, and the pain spreads across operator
// chains.
//! # rxRust: Reactive Extensions for Rust
//!
//! Zero-cost, type-safe implementation of [Reactive Extensions](http://reactivex.io/).
//!
//! ## Quick Start
//!
//! ```rust
//! use rxrust::prelude::*;
//!
//! // Local context: No locks, optimal for single-thread
//! Local::from_iter(0..10)
//!   .filter(|v| v % 2 == 0)
//!   .map(|v| v * 2)
//!   .subscribe(|v| println!("Value: {}", v));
//! ```
//!
//! ## Key Concepts
//!
//! | Type | Description |
//! |------|-------------|
//! | [`Local`] / [`Shared`] | Execution contexts (single-thread vs thread-safe) |
//! | [`Observable`] | The core trait defining stream operations |
//! | [`Observer`] | Consumes `next`, `error`, and `complete` events |
//! | [`Subscription`] | Handle to cancel an active subscription |
//!
//! ## 📚 Documentation
//!
//! For comprehensive guides, see the **[Online Guide](https://rxrust.github.io/rxRust/)**:
//!
//! - [Getting Started](https://rxrust.github.io/rxRust/getting_started.html)
//! - [Core Concepts](https://rxrust.github.io/rxRust/core_concepts.html)
//! - [Operators Reference](https://rxrust.github.io/rxRust/operators.html)
//! - [Cookbook](https://rxrust.github.io/rxRust/cookbook.html)
//!
//! ## Feature Flags
//!
//! - **`scheduler`** (default): Tokio-based schedulers for timing operators
//! - **`nightly`**: Experimental features requiring nightly Rust
//!
//! [`Local`]: prelude::Local
//! [`Shared`]: prelude::Shared
//! [`Observable`]: observable::Observable
//! [`Observer`]: observer::Observer
//! [`Subscription`]: subscription::Subscription
#[cfg(test)]
#[cfg(target_arch = "wasm32")]
#[wasm_bindgen::prelude::wasm_bindgen(start)]
pub fn __rxrust_wasm_init() { console_error_panic_hook::set_once(); }

// Main modules (formerly v1)
pub mod context;
pub mod factory;
pub mod observable;
pub mod observer;
pub mod ops;
pub mod prelude;
pub mod rc;
pub mod scheduler;
pub mod subject;
pub mod subscription;

// Re-export the prelude module
pub use prelude::*;

pub use crate::scheduler::{Duration, Instant};
#[cfg(feature = "scheduler")]
pub use crate::scheduler::{LocalScheduler, SharedScheduler};

// Bring external markdown files (README + guide/**/*.md) into Cargo-driven
// doctests. This module is only compiled for rustdoc doctest builds.

#[cfg(all(doctest, not(target_arch = "wasm32")))]
mod __markdown_doctests {
  // Split into per-file modules so doctest failures point at a meaningful
  // module name (instead of everything collapsing into `__markdown_doctests`).
  mod readme {
    #![doc = include_str!("../README.md")]
  }

  mod guide_summary {
    #![doc = include_str!("../guide/SUMMARY.md")]
  }

  mod guide_introduction {
    #![doc = include_str!("../guide/introduction.md")]
  }

  mod guide_getting_started {
    #![doc = include_str!("../guide/getting_started.md")]
  }

  mod guide_core_concepts {
    #![doc = include_str!("../guide/core_concepts.md")]
  }

  mod guide_core_concepts_context {
    #![doc = include_str!("../guide/core_concepts/context.md")]
  }

  mod guide_core_concepts_scheduler {
    #![doc = include_str!("../guide/core_concepts/scheduler.md")]
  }

  mod guide_core_concepts_type_erasure {
    #![doc = include_str!("../guide/core_concepts/type_erasure.md")]
  }

  mod guide_async_interop {
    #![doc = include_str!("../guide/async_interop.md")]
  }

  mod guide_cookbook {
    #![doc = include_str!("../guide/cookbook.md")]
  }

  mod guide_cookbook_gui {
    #![doc = include_str!("../guide/cookbook/gui.md")]
  }

  mod guide_cookbook_wasm {
    #![doc = include_str!("../guide/cookbook/wasm.md")]
  }

  mod guide_cookbook_auto_save {
    #![doc = include_str!("../guide/cookbook/auto_save.md")]
  }

  mod guide_cookbook_heartbeat {
    #![doc = include_str!("../guide/cookbook/heartbeat.md")]
  }

  mod guide_cookbook_state_store {
    #![doc = include_str!("../guide/cookbook/state_store.md")]
  }

  mod guide_operators {
    #![doc = include_str!("../guide/operators.md")]
  }

  mod guide_advanced {
    #![doc = include_str!("../guide/advanced.md")]
  }

  mod guide_advanced_architecture_deep_dive {
    #![doc = include_str!("../guide/advanced/architecture_deep_dive.md")]
  }

  mod guide_advanced_custom_scheduling {
    #![doc = include_str!("../guide/advanced/custom_scheduling.md")]
  }

  mod guide_advanced_custom_operators {
    #![doc = include_str!("../guide/advanced/custom_operators.md")]
  }

  mod guide_contributing {
    #![doc = include_str!("../guide/contributing.md")]
  }
}