Struct ZipTransformer 

pub struct ZipTransformer<T: Debug + Clone + Send + Sync + 'static> {
    pub config: TransformerConfig<Vec<T>>,
    pub _phantom: PhantomData<T>,
}

A transformer that zips items from multiple streams into vectors.

This transformer collects items from multiple input streams and combines them into vectors, emitting one vector per combination of items from each stream.

Fields

config: TransformerConfig<Vec<T>>

Configuration for the transformer, including error handling strategy.

_phantom: PhantomData<T>

Phantom data to track the type parameter.

Implementations

impl<T: Debug + Clone + Send + Sync + 'static> ZipTransformer<T>

pub fn new() -> Self

Creates a new ZipTransformer.

pub fn with_error_strategy(self, strategy: ErrorStrategy<Vec<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: Clone + Debug + Clone + Send + Sync + 'static> Clone for ZipTransformer<T>

fn clone(&self) -> ZipTransformer<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Clone + Send + Sync + 'static> Default for ZipTransformer<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T: Debug + Clone + Send + Sync + 'static> Input for ZipTransformer<T>

type Input = Vec<T>

The type of items produced by this input stream.

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

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

impl<T: Debug + Clone + Send + Sync + 'static> Output for ZipTransformer<T>

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: Debug + Clone + Send + Sync + 'static> Transformer for ZipTransformer<T>

type InputPorts = (Vec<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<Vec<T>>)

Sets the configuration implementation.

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

Returns a reference to the configuration implementation.

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

Returns a mutable reference to the configuration implementation.

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

Handles an error that occurred during stream processing.

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

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.