Struct Fallback 

pub struct Fallback<F> { /* private fields */ }

Trait Implementations

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

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

impl<Ctx, E, F> DispatchEvent<Ctx> for Fallback<F>

where F: AsyncFnMut(Event, &mut Ctx) -> Result<StreamEvents, E>,

type Error = E

type Future<'s> = Pin<Box<dyn Future<Output = Result<StreamEvents, E>> + 's>> where Self: 's, Ctx: 's

fn dispatch_event<'s>( &'s mut self, ev: Event, ctx: &'s mut Ctx, ) -> Result<Self::Future<'s>, (Event, &'s mut Ctx)>