Struct ActionDispatch 

pub struct ActionDispatch<A, S, C> { /* private fields */ }

Action Dispatch. Encasulate epic logic in a single future.

Implementations

impl<A, S, C> ActionDispatch<A, S, C>

where A: Clone + Send + 'static, S: Send + 'static, C: Send + 'static,

pub fn execute<F, Fut>( actions: Actions<A, S, C>, spawner: TaskSpawner, f: F, ) -> impl Stream<Item = Result<A, Error>>

where F: FnOnce(Self) -> Fut, Fut: Future<Output = Result<(), Error>> + Send + 'static,

Execute a stateful futures that dispatches/reacts to actions.

pub fn execute_with_response<F, Fut, R, O, E>( actions: Actions<A, S, C>, spawner: TaskSpawner, f: F, response: R, ) -> impl Stream<Item = Result<A, Error>>

where F: FnOnce(Self) -> Fut, Fut: Future<Output = Result<O, E>> + Send + 'static, R: FnOnce(Result<O, E>) -> A + Send + 'static,

Execute a stateful futures that dispatches/reacts to actions with an final result action.

pub fn dispatch(&self, item: A) -> bool

Dispatch an action. Actions are dispatched immediately.

pub fn dispatch_result(&self, item: Result<A, Error>) -> bool

Dispatch an action result. Actions are dispatched immediately.

pub async fn request<F, O>(&self, request: A, response: F) -> Result<O, Error>

where F: for<'a> Fn(&'a A) -> Option<O> + Clone + Send + 'static,

Request/Response. Dispatch request and wait for first response.

Trait Implementations

impl<A, S, C> Clone for ActionDispatch<A, S, C>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.