Struct FlatMapTransform 

pub struct FlatMapTransform<F>
where
    F: Fn(Vec<u8>) -> Vec<Vec<u8>> + Send + Sync,
{ /* private fields */ }

FlatMap transformation.

Implementations

impl<F> FlatMapTransform<F>

where F: Fn(Vec<u8>) -> Vec<Vec<u8>> + Send + Sync,

pub fn new(mapper: F) -> Self

Create a new flat map transformation.

pub fn apply(&self, element: StreamElement) -> Vec<StreamElement>

Apply the transformation to an element.

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

Apply the transformation to a message.