Struct BatchTransformer 

pub struct BatchTransformer<T>
where
    T: Debug + Clone + Send + Sync + 'static,
{
    pub size: usize,
    pub config: TransformerConfig<T>,
    pub _phantom: PhantomData<T>,
}

A transformer that groups items in a stream into batches of a specified size.

This transformer collects incoming items until the specified size is reached, then emits them as a Vec<T>.

Fields

size: usize

The number of items to include in each batch.

config: TransformerConfig<T>

Configuration for the transformer, including error handling strategy.

_phantom: PhantomData<T>

Phantom data to track the input type parameter.

Implementations

impl<T> BatchTransformer<T>

where T: Debug + Clone + Send + Sync + 'static,

pub fn new(size: usize) -> Result<Self, Box<StreamError<T>>>

Creates a new BatchTransformer with the given batch size.

Arguments

• size - The number of items to include in each batch. Must be greater than zero.

Returns

A Result containing the BatchTransformer if size is valid, or an error if size is zero.

pub fn with_error_strategy(self, strategy: ErrorStrategy<T>) -> 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<T> Input for BatchTransformer<T>

where T: Debug + Clone + Send + Sync + 'static,

type Input = T

The type of items produced by this input stream.

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

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

impl<T> Output for BatchTransformer<T>

where T: Debug + Clone + Send + Sync + 'static,

type Output = Vec<T>

The type of items produced by this output stream.

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

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

impl<T> Transformer for BatchTransformer<T>

where T: Debug + Clone + Send + Sync + 'static,

type InputPorts = (T,)

The input port tuple type for this transformer.

type OutputPorts = (Vec<T>,)

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<T>)

Sets the configuration implementation.

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

Returns a reference to the configuration implementation.

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

Returns a mutable reference to the configuration implementation.

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

Handles an error that occurred during stream processing.

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

Creates an error context for error reporting.

fn component_info(&self) -> ComponentInfo

Returns information about the component for error reporting.

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.