rx_core_observable_timer 0.2.1

timer observable for rx_core
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12

use std::time::Duration;

use rx_core_common::{Scheduler, SchedulerHandle};

use crate::observable::TimerObservable;

pub fn timer<S>(duration: Duration, scheduler: SchedulerHandle<S>) -> TimerObservable<S>
where
	S: Scheduler,
{
	TimerObservable::new(duration, scheduler)
}