rx-rust 0.3.0

Reactive Programming in Rust inspired by ReactiveX https://reactivex.io/
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

pub mod boxed_observable;
pub mod cloneable_boxed_observable;
pub mod observable_ext;

use crate::{
    disposable::subscription::Subscription, observer::Observer, utils::types::NecessarySendSync,
};

/// The `Observable` trait represents a source of events that can be observed by an `Observer`.
/// See <https://reactivex.io/documentation/observable.html>
pub trait Observable<'or, 'sub, T, E> {
    /// Subscribes an observer to this observable. When an observer is subscribed, it will start receiving events from the observable.
    /// The `subscribe` method returns a `Subscription` which can be used to unsubscribe the observer from the observable.
    /// We use `Subscription` struct instead of trait like `impl Cancellable`, because we need to cancel the subscription when the `Subscription` is dropped. It's not possible to implement Drop for a trait object.
    fn subscribe(
        self,
        observer: impl Observer<T, E> + NecessarySendSync + 'or,
    ) -> Subscription<'sub>;
}