Trait ConcurrentDispatchEvent 

pub trait ConcurrentDispatchEvent<Ctx>
where
    Ctx: 'static + Send,
{
    type Error: 'static + Send;
    type Future: 'static + Send + Future<Output = Result<StreamEvents, Self::Error>>;

    // Required method
    fn concurrent_dispatch_event(
        &self,
        ev: Event,
        ctx: Ctx,
    ) -> Result<Self::Future, (Event, Ctx)>;
}

Required Associated Types

type Error: 'static + Send

type Future: 'static + Send + Future<Output = Result<StreamEvents, Self::Error>>

Required Methods

fn concurrent_dispatch_event( &self, ev: Event, ctx: Ctx, ) -> Result<Self::Future, (Event, Ctx)>

Implementors

impl<Ctx, D1, D2> ConcurrentDispatchEvent<Ctx> for Intercept<D1, D2>

where Ctx: 'static + Send, D1: ConcurrentDispatchEvent<Ctx>, D2: ConcurrentDispatchEvent<Ctx, Error = D1::Error>,

type Error = <D1 as ConcurrentDispatchEvent<Ctx>>::Error

type Future = Either<<D1 as ConcurrentDispatchEvent<Ctx>>::Future, <D2 as ConcurrentDispatchEvent<Ctx>>::Future>

impl<Ctx, E, F, Fut> ConcurrentDispatchEvent<Ctx> for Fallback<F>

where Ctx: 'static + Send, E: 'static + Send, F: Fn(Event, Ctx) -> Fut, Fut: 'static + Send + Future<Output = Result<StreamEvents, E>>,

type Error = E

type Future = Fut

impl<Ctx, Ev, E, F, Fut> ConcurrentDispatchEvent<Ctx> for Match<Ev, F>

where Ctx: 'static + Send, Ev: 'static + EventData, E: 'static + Send, F: Fn(Arc<Ev>, Ctx) -> Fut, Fut: 'static + Send + Future<Output = Result<StreamEvents, E>>,

type Error = E

type Future = Fut