another-rxrust 0.0.46

A different implementation than `rxRust` for easier use of `ReactiveX` in `Rust`.
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

use crate::prelude::{schedulers::IScheduler, web::*};
use std::time;

#[derive(Clone)]
pub struct AsyncScheduler {}

impl AsyncScheduler {
  pub fn new() -> AsyncScheduler {
    AsyncScheduler {}
  }
}

impl IScheduler<'static> for AsyncScheduler {
  fn post<F>(&self, f: F)
  where
    F: Fn() + Send + Sync + 'static,
  {
    set_timeout(f, time::Duration::from_millis(0));
  }
  fn abort(&self) {}
}

pub fn async_scheduler<'a>() -> fn() -> AsyncScheduler {
  || AsyncScheduler::new()
}