Trait FrameProcessor

pub trait FrameProcessor<F> {
    // Required method
    fn process<'life0, 'async_trait>(
        &'life0 mut self,
        frame_data: F,
    ) -> Pin<Box<dyn Future<Output = Option<F>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Required Methods

fn process<'life0, 'async_trait>( &'life0 mut self, frame_data: F, ) -> Pin<Box<dyn Future<Output = Option<F>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Implementors

impl<F> FrameProcessor<F> for AsyncFunction<F>

where F: Send,

impl<F> FrameProcessor<F> for CloneSwitch<F>

where F: Debug + Clone + Default + Send + 'static,

impl<F> FrameProcessor<F> for Switch<F>

where F: Debug + Send,

impl<F, E> FrameProcessor<F> for OnErrorSwitch<F, E>

where E: Send + PartialEq, F: FrameError<E> + Debug + Send + 'static,

impl<F, P, K> FrameProcessor<F> for DepoolingSwitch<F, P, K>

where P: Send, K: Eq + Hash + Send, F: Debug + FrameProperties<P, K> + Send + 'static,

impl<F, P, K> FrameProcessor<F> for PoolingSwitch<F, P, K>

where P: Copy + Send, K: Copy + Send, F: Debug + FrameProperties<P, K> + Send + 'static,

impl<F: Send + 'static> FrameProcessor<F> for Ticker

impl<F: Send> FrameProcessor<F> for Sequential<F>

impl<F: Send> FrameProcessor<F> for Function<F>

impl<FD, FN> FrameProcessor<FD> for Closure<FD, FN>

where FD: Send, FN: Fn(FD) -> Option<FD> + Send,