Struct FilterTransform 

pub struct FilterTransform<F>
where
    F: Fn(&StreamElement) -> bool + Send + Sync,
{ /* private fields */ }

Filter transformation.

Implementations

impl<F> FilterTransform<F>

where F: Fn(&StreamElement) -> bool + Send + Sync,

pub fn new(predicate: F) -> Self

Create a new filter transformation.

pub fn test(&self, element: &StreamElement) -> bool

Check if an element passes the filter.

pub fn apply_message(&self, message: StreamMessage) -> Option<StreamMessage>

Apply the filter to a message.