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
30
31
32
33

use super::Scheduler;
use crate::{
    disposable::{Disposable, bound_drop_disposal::BoundDropDisposal},
    utils::types::MaybeSend,
};
use std::time::Duration;

/// Schedules tasks using the smol runtime utilities.
#[derive(Debug, Clone)]
pub struct SmolScheduler;

/// Provides the smol-backed `Scheduler` implementation.
impl Scheduler for SmolScheduler {
    type D = smol::Task<()>;

    fn spawn_future(
        &self,
        future: impl Future<Output = ()> + MaybeSend + 'static,
    ) -> BoundDropDisposal<Self::D> {
        let handle = smol::spawn(future);
        BoundDropDisposal::new(handle)
    }

    fn sleep(&self, duration: Duration) -> impl Future + MaybeSend + 'static + use<> {
        smol::Timer::after(duration)
    }
}

impl Disposable for smol::Task<()> {
    fn dispose(self) {
        // Dropping a `smol::Task` cancels it.
    }
}