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

//! # Operators
//!
//! All operator implementations for transforming, filtering, and combining
//! observable streams.
//!
//! ## Operator Categories
//!
//! ### Transformation
//! - [`map`] - Transform each item
//! - [`filter_map`] - Transform and filter in one step
//! - [`scan`] - Accumulate with intermediate emissions
//!
//! ### Filtering
//! - [`filter`] - Pass items matching a predicate
//! - [`take`] / [`skip`] - Limit emissions
//! - [`distinct`] - Remove duplicates
//!
//! ### Combination
//! - [`merge`] - Interleave multiple streams
//! - [`zip`] - Pair items from multiple streams
//! - [`combine_latest`] - Combine latest values
//!
//! ### Timing
//! - [`debounce`] - Emit after quiet period
//! - [`throttle`] - Rate limit emissions
//! - [`delay`] - Shift emissions in time
//!
//! For interactive marble diagrams, see [ReactiveX.io](http://reactivex.io/documentation/operators.html).
//! For Rust-specific usage, see the [Operators Guide](https://rxrust.github.io/rxRust/operators.html).

pub mod average;
pub mod box_it;
pub mod buffer;
pub mod buffer_count;
pub mod buffer_time;
pub mod collect;
pub mod combine_latest;
pub mod contains;
pub mod debounce;
pub mod default_if_empty;
pub mod delay;
pub mod distinct;
pub mod distinct_until_changed;
pub mod filter;
pub mod filter_map;
pub mod finalize;
pub mod flat_map;
pub mod group_by;
pub mod into_future;
pub mod into_stream;
pub mod last;
pub mod lifecycle;
pub mod map;
pub mod map_err;
pub mod map_to;
pub mod merge;
pub mod merge_all;
pub mod observe_on;
pub mod pairwise;
pub mod reduce;
pub mod ref_count;
pub mod retry;
pub mod sample;
pub mod scan;
pub mod skip;
pub mod skip_last;
pub mod skip_until;
pub mod skip_while;
pub mod start_with;
pub mod subscribe_on;
pub mod switch_map;
pub mod take;
pub mod take_last;
pub mod take_until;
pub mod take_while;
pub mod tap;
pub mod throttle;
pub mod with_latest_from;
pub mod zip;

// Re-exports
pub use average::*;
pub use box_it::*;
pub use buffer::*;
pub use buffer_count::*;
pub use buffer_time::*;
pub use collect::*;
pub use combine_latest::*;
pub use contains::*;
pub use debounce::*;
pub use default_if_empty::*;
pub use delay::*;
pub use distinct::*;
pub use distinct_until_changed::*;
pub use filter::*;
pub use filter_map::*;
pub use finalize::*;
pub use flat_map::*;
pub use group_by::*;
pub use into_future::*;
pub use into_stream::*;
pub use last::*;
pub use lifecycle::*;
pub use map::*;
pub use map_err::*;
pub use map_to::*;
pub use merge::*;
pub use merge_all::*;
pub use observe_on::*;
pub use pairwise::*;
pub use reduce::*;
pub use ref_count::*;
pub use retry::*;
pub use sample::*;
pub use scan::*;
pub use skip::*;
pub use skip_last::*;
pub use skip_until::*;
pub use skip_while::*;
pub use start_with::*;
pub use subscribe_on::*;
pub use switch_map::*;
pub use take::*;
pub use take_last::*;
pub use take_until::*;
pub use take_while::*;
pub use tap::*;
pub use throttle::*;
pub use with_latest_from::*;
pub use zip::*;

#[cfg(test)]
mod aggregation_tests;