flurx 0.1.6

Create reactive asynchronous data flow
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

pub trait Dispatch<State> {
    /// Dispatch the new state to [`Store`](crate::store::Store).
    ///
    /// This method is used in [`Scheduler::run`](crate::scheduler::Scheduler::run) 
    /// and executes [`Reactors`](crate::scheduler::Reactor) based on the latest state generated by this method.
    ///
    fn dispatch(self, current: State) -> State;
}


impl<State, F> Dispatch<State> for F
    where F: FnOnce(State) -> State
{
    #[inline]
    fn dispatch(self, current: State) -> State {
        (self)(current)
    }
}