Crate rxr

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 observable::timestamp::TimestampedEmit;

pub use observer::Observer;

pub use subjects::Subject;

pub use subscribe::Subscribeable;

pub use subscribe::Unsubscribeable;

pub use observable::*;

pub use subscription::*;

Modules

observable

The observable module provides the building blocks for creating and manipulating observables, allowing for reactive programming in Rust.

observer

The observer module defines the Observer 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 the rxr library internally.

subjects

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.

subscription

Provides structures and traits related to subscription management.