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
21
22
23
24
25
26
27
28
29
30
31
32

#[cfg(feature = "default-selectors")]
pub mod repeat;
#[cfg(feature = "default-selectors")]
pub mod wait;
#[cfg(feature = "default-selectors")]
pub mod delay;
#[cfg(feature = "default-selectors")]
pub mod once;


/// Selector defines what a task created by [`ReactiveTask`] will do.
///
/// [`ReactiveTask`]: crate::prelude::ReactiveTask
pub trait Selector<State> {
    type Output;

    /// The Option value in the output indicates that Future is still pending if Some, or that the task is ready if Some.
    fn select(&self, state: State) -> Option<Self::Output>;
}


impl<State, Output, F> Selector<State> for F
    where F: Fn(State) -> Option<Output> + Unpin
{
    type Output = Output;

    #[inline]
    fn select(&self, state: State) -> Option<Self::Output> {
        (self)(state)
    }
}