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 call to_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 use Fork 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 dur time into the future, and will repeat every dur interval after.
interval_at	Creates a observable which will fire at the time specified by at, and then will repeat every dur interval after
interval_observable
local_subject_raw_subscribe_impl
merge_subscribe
observer_impl_proxy_directly
raw_subscribe
subscription_direct_impl_proxy
subscription_impl