Struct VecConsumer 

pub struct VecConsumer<T>
where
    T: Debug + Clone + Send + Sync + 'static,
{
    pub vec: Vec<T>,
    pub config: ConsumerConfig<T>,
}

A consumer that collects items into a Vec.

This consumer collects all items from the stream into an internal Vec, preserving the order in which they were received.

Fields

vec: Vec<T>

The internal Vec where items are collected.

config: ConsumerConfig<T>

Configuration for the consumer, including error handling strategy.

Implementations

impl<T> VecConsumer<T>

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

pub fn new() -> Self

Creates a new VecConsumer with an empty Vec.

pub fn with_capacity(capacity: usize) -> Self

Creates a new VecConsumer with a pre-allocated Vec capacity.

Arguments

• capacity - The initial capacity of the internal Vec.

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

Sets the error handling strategy for this consumer.

Arguments

• strategy - The error handling strategy to use.

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

Sets the name for this consumer.

Arguments

• name - The name to assign to this consumer.

pub fn into_vec(self) -> Vec<T>

Consumes the consumer and returns the collected Vec.

Returns

The Vec containing all collected items in order.

Trait Implementations

impl<T> Clone for VecConsumer<T>

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

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T> Consumer for VecConsumer<T>

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

type InputPorts = (T,)

The input port tuple type for this consumer.

fn consume<'life0, 'async_trait>( &'life0 mut self, stream: Self::InputStream, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Consumes a stream of items.

fn set_config_impl(&mut self, config: ConsumerConfig<T>)

Internal implementation for setting configuration.

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

Internal implementation for getting configuration.

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

Internal implementation for getting mutable configuration.

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

Handles an error according to the consumer’s error strategy.

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

Creates an error context for the given item.

fn component_info(&self) -> ComponentInfo

Returns information about this consumer component.

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

where Self: Sized + Clone,

Creates a new consumer instance with the given configuration.

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

Sets the configuration for this consumer.

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

Returns a reference to the consumer’s configuration.

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

Returns a mutable reference to the consumer’s configuration.

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

where Self: Sized,

Sets the name for this consumer.

impl<T> Default for VecConsumer<T>

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

fn default() -> Self

Returns the “default value” for a type.

impl<T> Input for VecConsumer<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.