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
20
21
22
23
24
25
26
27
28
29
30

pub mod boxed_observer;
pub mod callback_observer;

use educe::Educe;

/// Represents the termination state of an operation, which can either be completed successfully or with an error.
#[derive(Educe)]
#[educe(Debug, Clone, PartialEq, Eq)]
pub enum Termination<E> {
    /// Indicates that the operation has completed successfully.
    Completed,
    /// Indicates that the operation has completed with an error.
    Error(E),
}

/// A trait for observing the progress and termination state of an operation.
pub trait Observer<T, E> {
    /// Called when the next value in the operation is available.
    fn on_next(&mut self, value: T);

    /// Called when the operation has reached its termination state.
    fn on_termination(self, termination: Termination<E>);
}

#[derive(Educe)]
#[educe(Debug, Clone, PartialEq, Eq)]
pub enum Event<T, E> {
    Next(T),
    Termination(Termination<E>),
}