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

//! Prelude module for convenient imports
//!
//! This module re-exports commonly used types and traits for easy access.

// Context types and traits
// Factory trait
// Boxed types (Generic)
// Connectable trait (unified fork/connect/ref_count)
// Core traits
// Creation/Factories
// Scheduler-specific Observable aliases
#[cfg(feature = "scheduler")]
pub use crate::observable::{
  LocalBoxedObservable, LocalBoxedObservableClone, LocalBoxedObservableMutRef,
  LocalBoxedObservableMutRefClone, SharedBoxedObservable, SharedBoxedObservableClone,
  SharedBoxedObservableMutRef, SharedBoxedObservableMutRefClone,
};
// Observer trait
pub use crate::observer::Observer;
// Operators
pub use crate::ops::{into_future::*, into_stream::*};
// Test Scheduler
#[cfg(test)]
pub use crate::scheduler::test_scheduler::TestScheduler;
// Scheduler Core types
pub use crate::scheduler::{Duration, Instant, Schedulable, Scheduler};
// Default Schedulers
#[cfg(feature = "scheduler")]
pub use crate::scheduler::{LocalScheduler, SharedScheduler};
// Scheduler Task types
pub use crate::scheduler::{SleepProvider, Task, TaskHandle, TaskState};
// Subject
pub use crate::subject::*;
// Subscription
pub use crate::subscription::*;
pub use crate::{
  context::*,
  factory::ObservableFactory,
  observable::{
    BoxedCoreObservable, BoxedCoreObservableClone, BoxedCoreObservableMutRef,
    BoxedCoreObservableMutRefClone, BoxedCoreObservableMutRefSend,
    BoxedCoreObservableMutRefSendClone, BoxedCoreObservableSend, BoxedCoreObservableSendClone,
    Connectable, ConnectableObservable, CoreObservable, Defer, DynCoreObservable,
    DynCoreObservableClone, Empty, FromFn, FromFuture, FromIter, FromStream, Interval,
    IntoBoxedCoreObservable, Never, Observable, ObservableType, Of, ThrowErr, Timer,
  },
  ops::throttle::ThrottleEdge,
};