Struct StdoutConsumer 

pub struct StdoutConsumer<T>
where
    T: Debug + Clone + Send + Sync + Display + 'static,
{
    pub config: ConsumerConfig<T>,
}

A consumer that writes items to standard output (stdout).

This consumer writes each item from the stream to stdout, one per line. It’s useful for building command-line tools that output to stdout.

Example

use streamweave_stdio::StdoutConsumer;
use streamweave::Pipeline;

let consumer = StdoutConsumer::new();
let pipeline = Pipeline::new()
    .producer(/* ... */)
    .transformer(/* ... */)
    .consumer(consumer);

Fields

config: ConsumerConfig<T>

Configuration for the consumer, including error handling strategy.

Implementations

impl<T> StdoutConsumer<T>

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

pub fn new() -> Self

Creates a new StdoutConsumer with default configuration.

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.

Trait Implementations

impl<T> Consumer for StdoutConsumer<T>

where T: Debug + Clone + Send + Sync + Display + '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 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 StdoutConsumer<T>

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

fn default() -> Self

Returns the “default value” for a type.

impl<T> Input for StdoutConsumer<T>

where T: Debug + Clone + Send + Sync + Display + '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.