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

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
merge_subscribe
raw_subscribe
subscription_impl