Struct flurx::scheduler::Scheduler

pub struct Scheduler<'state, 'future, State> { /* private fields */ }

Implementations

impl<'state, 'future, State> Scheduler<'state, 'future, State>

where State: Clone + 'state + 'future, 'state: 'future,

pub const fn new() -> Scheduler<'state, 'future, State>

Creates the empty scheduler.

pub const fn not_exists_reactor(&self) -> bool

pub const fn exists_reactor(&self) -> bool

pub fn schedule<F, Fut>(&mut self, f: F)

where F: FnOnce(ReactiveTask<'state, State>) -> Fut, Fut: Future<Output = ()> + 'future,

Schedule the new [Reactor].

The reality [Reactor] is Future, it is polled once every time Scheduler::run is called.

Examples

use flurx::prelude::*;

#[tokio::main]
async fn main(){
    let mut scheduler = Scheduler::<usize>::new();
    scheduler.schedule(|task|async move{
        // (1)
        task.will(wait::until(|state: usize|{
            state < 2
        })).await;
    });
    // state is 0, (1) returns [`Future::Pending`].
    scheduler.run(0).await;
    // state is 1, (1) returns [`Future::Pending`].
    scheduler.run(1).await;
    // state is 2, (1) returns [`Future::Ready(2)`].
    scheduler.run(2).await;
}

pub async fn run(&mut self, state: State)

Poll all registered Reactors once each.

Trait Implementations

impl<'state, 'future, State> Default for Scheduler<'state, 'future, State>

where State: Clone + 'state + 'future, 'state: 'future,

fn default() -> Self

Returns the “default value” for a type.