Struct MapOperator 

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

A map operator.

Implementations

impl<F> MapOperator<F>

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

pub fn new(mapper: F, name: String) -> Self

Create a new map operator.

Trait Implementations

impl<F> StreamOperator for MapOperator<F>

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

fn process<'life0, 'async_trait>( &'life0 mut self, message: StreamMessage, ) -> Pin<Box<dyn Future<Output = Result<Vec<StreamMessage>>> + Send + 'async_trait>>

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

Process a stream message.

fn name(&self) -> &str

Get the operator name.

fn initialize<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Initialize the operator.

fn finalize<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Finalize the operator.