Struct MapTransform 

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

Map transformation.

Implementations

impl<F> MapTransform<F>

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

pub fn new(mapper: F) -> Self

Create a new map transformation.

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

Apply the transformation to an element.

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

Apply the transformation to a message.