Struct MapTransformer 

pub struct MapTransformer<F, I, O>
where
    F: FnMut(I) -> O + Send + Clone + 'static,
    I: Debug + Clone + Send + Sync + 'static,
    O: Debug + Clone + Send + Sync + 'static,
{
    pub f: F,
    pub config: TransformerConfig<I>,
    pub _phantom_i: PhantomData<I>,
    pub _phantom_o: PhantomData<O>,
}

A transformer that applies a function to each item in the stream.

This transformer takes each input item and applies a function to transform it into an output item, creating a one-to-one mapping.

Fields

f: F

The function to apply to each input item.

config: TransformerConfig<I>

Configuration for the transformer, including error handling strategy.

_phantom_i: PhantomData<I>

Phantom data to track the input type parameter.

_phantom_o: PhantomData<O>

Phantom data to track the output type parameter.

Implementations

impl<F, I, O> MapTransformer<F, I, O>

where F: FnMut(I) -> O + Send + Clone + 'static, I: Debug + Clone + Send + Sync + 'static, O: Debug + Clone + Send + Sync + 'static,

pub fn new(f: F) -> Self

Creates a new MapTransformer with the given function.

Arguments

• f - The function to apply to each input item.

pub fn with_error_strategy(self, strategy: ErrorStrategy<I>) -> Self

Sets the error handling strategy for this transformer.

Arguments

• strategy - The error handling strategy to use.

pub fn with_name(self, name: String) -> Self

Sets the name for this transformer.

Arguments

• name - The name to assign to this transformer.

Trait Implementations

impl<F, I, O> Clone for MapTransformer<F, I, O>

where F: FnMut(I) -> O + Send + Clone + 'static, I: Debug + Clone + Send + Sync + 'static, O: Debug + Clone + Send + Sync + 'static,

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<F, I, O> Input for MapTransformer<F, I, O>

where F: FnMut(I) -> O + Send + Clone + 'static, I: Debug + Clone + Send + Sync + 'static, O: Debug + Clone + Send + Sync + 'static,

type Input = I

The type of items produced by this input stream.

type InputStream = Pin<Box<dyn Stream<Item = I> + Send>>

The input stream type that yields items of type Self::Input.

impl<F, I, O> Output for MapTransformer<F, I, O>

where F: FnMut(I) -> O + Send + Clone + 'static, I: Debug + Clone + Send + Sync + 'static, O: Debug + Clone + Send + Sync + 'static,

type Output = O

The type of items produced by this output stream.

type OutputStream = Pin<Box<dyn Stream<Item = O> + Send>>

The output stream type that yields items of type Self::Output.

impl<F, I, O> Transformer for MapTransformer<F, I, O>

where F: FnMut(I) -> O + Send + Clone + 'static, I: Debug + Clone + Send + Sync + 'static, O: Debug + Clone + Send + Sync + 'static,

type InputPorts = (I,)

The input port tuple type for this transformer.

type OutputPorts = (O,)

The output port tuple type for this transformer.

fn transform(&mut self, input: Self::InputStream) -> Self::OutputStream

Transforms a stream of input items into a stream of output items.

fn set_config_impl(&mut self, config: TransformerConfig<I>)

Sets the configuration implementation.

fn get_config_impl(&self) -> &TransformerConfig<I>

Returns a reference to the configuration implementation.

fn get_config_mut_impl(&mut self) -> &mut TransformerConfig<I>

Returns a mutable reference to the configuration implementation.

fn handle_error(&self, error: &StreamError<I>) -> ErrorAction

Handles an error that occurred during stream processing.

fn create_error_context(&self, item: Option<I>) -> ErrorContext<I>

Creates an error context for error reporting.

fn component_info(&self) -> ComponentInfo

Returns information about the component for error reporting.

fn with_config(&self, config: TransformerConfig<Self::Input>) -> Self

where Self: Sized + Clone,

Creates a new transformer instance with the given configuration.

fn set_config(&mut self, config: TransformerConfig<Self::Input>)

Sets the configuration for this transformer.

fn config(&self) -> &TransformerConfig<Self::Input>

Returns a reference to the transformer’s configuration.

fn config_mut(&mut self) -> &mut TransformerConfig<Self::Input>

Returns a mutable reference to the transformer’s configuration.

fn with_name(self, name: String) -> Self

where Self: Sized,

Sets the name for this transformer.