[−][src]Crate rxrust
Reactive extensions library for Rust: a library for Reactive Programming using Observables, to make it easier to compose asynchronous or callback-based code.
There are two core abstractions that are unique to RxRust:
- IntoShared: By default, RxRust always provides
a single thread version to get the best performance, but a thread-safe
implementation also exists. The trait
IntoShared
will convert a local-thread struct to thread-safe version. So we can callto_shared
method to ensure operators or subscription can shared between threads. - Fork: In Rxrust all operators consume the
upstream except
Fork
, so operators always combine a single-chain and can only subscribe once. We useFork
to fork the stream.
Modules
observable | |
ops | |
prelude | |
scheduler | |
subject | |
subscribable | |
subscriber | |
subscription |
Macros
impl_subject_copy_for_copy | |
impl_subject_copys | |
interval | Creates an observable which will fire at |
interval_at | Creates a observable which will fire at the time specified by |
interval_observable | |
local_subject_raw_subscribe_impl | |
merge_subscribe | |
observer_impl_proxy_directly | |
raw_subscribe | |
subscription_direct_impl_proxy | |
subscription_impl |