Struct QueueFn 

pub struct QueueFn<I, O, F = fn(Result<&I, Error>) -> Option<Result<O, Error>>>
where
    I: ReadRequest + ?Sized,
    O: Send,
    F: FnMut(Result<&I, Error>) -> Option<Result<O, Error>> + Send,
{ /* private fields */ }

Subscription queue that stores all received values, applying F to them.

If F returned None the value is filtered out.

Trait Implementations

impl<I, O, F> Queue for QueueFn<I, O, F>

where I: ReadRequest + ?Sized, O: Send, F: FnMut(Result<&I, Error>) -> Option<Result<O, Error>> + Send,

type Request = I

type Output = O

fn push(&mut self, input: Result<&Self::Request, Error>)

Called immediately on channel updates.

fn pop(&mut self) -> Option<Result<Self::Output, Error>>

Called when user tries to extract data from Subscription stream.