Struct VecProducer 

pub struct VecProducer<T>
where
    T: Debug + Clone + Send + Sync + 'static,
{
    pub data: Vec<T>,
    pub config: ProducerConfig<T>,
}

A producer that yields items from a Vec.

This producer iterates over all items in the Vec and produces them in order.

Fields

data: Vec<T>

The Vec data to produce from.

config: ProducerConfig<T>

Configuration for the producer, including error handling strategy.

Implementations

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

pub fn new(data: Vec<T>) -> Self

Creates a new VecProducer with the given Vec.

Arguments

• data - The Vec to produce items from.

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

Sets the error handling strategy for this producer.

Arguments

• strategy - The error handling strategy to use.

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

Sets the name for this producer.

Arguments

• name - The name to assign to this producer.

Trait Implementations

impl<T> Clone for VecProducer<T>

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

fn clone(&self) -> VecProducer<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> Output for VecProducer<T>

type Output = T

The type of items produced by this output stream.

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

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

impl<T: Debug + Clone + Send + Sync + 'static> Producer for VecProducer<T>

type OutputPorts = (T,)

The output port tuple type for this producer.

fn produce(&mut self) -> Self::OutputStream

Produces a stream of items.

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

Sets the configuration implementation.

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

Returns a reference to the configuration implementation.

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

Returns a mutable reference to the configuration implementation.

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

Handles an error that occurred during stream production.

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 with_config(&self, config: ProducerConfig<Self::Output>) -> Self

where Self: Sized + Clone,

Creates a new producer instance with the given configuration.

fn set_config(&mut self, config: ProducerConfig<Self::Output>)

Sets the configuration for this producer.

fn config(&self) -> &ProducerConfig<Self::Output>

Returns a reference to the producer’s configuration.

fn config_mut(&mut self) -> &mut ProducerConfig<Self::Output>

Returns a mutable reference to the producer’s configuration.

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

where Self: Sized,

Sets the name for this producer.