rx-rust 1.0.1

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

use crate::disposable::Disposable;

/// A disposal that disposes `first`, then `second`.
///
/// The front-to-back dispose order is a guarantee, not an implementation detail:
/// operators encode their semantics in it. For example, `DoBeforeDisposal` places
/// its callback in `first` to run before the source's disposal, while
/// `DoAfterDisposal` places it in `second` to run after.
pub struct ChainDisposal<D1, D2> {
    first: D1,
    second: D2,
}

impl<D1, D2> ChainDisposal<D1, D2> {
    pub fn new(first: D1, second: D2) -> Self {
        Self { first, second }
    }
}

impl<D1, D2> Disposable for ChainDisposal<D1, D2>
where
    D1: Disposable,
    D2: Disposable,
{
    fn dispose(self) {
        self.first.dispose();
        self.second.dispose();
    }
}