Expand description
§rxr
rxr
is an implementation of the reactive extensions for the Rust
programming language, inspired by the popular RxJS
library in JavaScript.
Currently, rxr
implements a smaller subset of operators compared to RxJS
.
§Design
rxr
supports Observables
and Subjects
. You define your own Observables
with
functionality you want. For examples on how to define your Observables
see the
Creating Observables
. Your Observables
can be synchronous or asynchronous. For
asynchronous Observables
, you can utilize OS threads or Tokio
tasks.
Re-exports§
pub use observer::Observer;
pub use subjects::Subject;
pub use subscribe::Subscribeable;
pub use subscribe::Unsubscribeable;
pub use observable::*;
pub use subscription::*;
Modules§
- The
observable
module provides the building blocks for creating and manipulating observables, allowing for reactive programming in Rust. - The
observer
module defines theObserver
trait, which is implemented by types responsible for observing and handling events emitted by observables. While optional for users to implement, this trait is mainly utilized by therxr
library internally. - The
subjects
module provides various types of subjects for handling and observing data streams. Subjects serve both as observers and observables, allowing multiple observers to concurrently subscribe to a single source and receive updates. - Provides structures and traits related to subscription management.