Trait reducer::SpawnDispatcher

pub trait SpawnDispatcher {
    fn spawn_dispatcher<D, A, E>(
        &mut self, 
        dispatcher: D
    ) -> Result<(AsyncDispatcher<A, E>, RemoteHandle<D::Output>), SpawnError>
    where
        D: Dispatcher<A, Output = Result<(), E>> + Sink<A, SinkError = E> + Send + 'static,
        A: Send + 'static,
        E: Send + 'static;
}

Trait for types that can spawn Dispatchers as an asynchronous task (requires async).

Required methods

fn spawn_dispatcher<D, A, E>(
    &mut self,
    dispatcher: D
) -> Result<(AsyncDispatcher<A, E>, RemoteHandle<D::Output>), SpawnError> where
    D: Dispatcher<A, Output = Result<(), E>> + Sink<A, SinkError = E> + Send + 'static,
    A: Send + 'static,
    E: Send + 'static, 

Spawns a Dispatcher as a task that will listen to actions dispatched through the AsyncDispatcher returned.

The task completes

• successfuly if AsyncDispatcher (or the last of its clones) is dropped.
• successfuly if RemoteHandle is is dropped, unless RemoteHandle::forget is called.
• with an error if Dispatcher::dispatch fails.
  • The error can be retrieved by polling RemoteHandle to completion.

Loading content...

Implementors

impl<S: ?Sized> SpawnDispatcher for S where
    S: Spawn, 

fn spawn_dispatcher<D, A, E>(
    &mut self,
    dispatcher: D
) -> Result<(AsyncDispatcher<A, E>, RemoteHandle<D::Output>), SpawnError> where
    D: Dispatcher<A, Output = Result<(), E>> + Sink<A, SinkError = E> + Send + 'static,
    A: Send + 'static,
    E: Send + 'static, 

Loading content...