Struct StreamingInput

pub struct StreamingInput { /* private fields */ }

Handles streaming input processing and colorization

Implementations

impl StreamingInput

pub fn new(config: PatternConfig, theme_name: &str) -> Result<Self>

Creates a new streaming input processor with the given configuration

Arguments

• config - Pattern configuration for color generation
• theme_name - Name of the color theme to use

Returns

A new StreamingInput instance or an error if initialization fails

pub fn process_stream<R: Read>(&mut self, reader: R) -> Result<()>

Processes input from a reader and writes colored output

Arguments

• reader - The input reader to process

Returns

Ok(()) if processing completes successfully, Error otherwise

pub fn set_buffer_capacity(&mut self, capacity: usize)

Sets the buffer capacity for reading

Arguments

• capacity - New buffer capacity in bytes

pub fn set_colors_enabled(&mut self, enabled: bool)

Enables or disables color output

Arguments

• enabled - Whether colors should be enabled

pub fn process_stdin(&mut self) -> Result<()>

Processes input from stdin with non-blocking reads

Returns

Ok(()) if processing completes successfully, Error otherwise

pub fn stats(&self) -> (usize, usize, f64)

Returns the current processing statistics

pub fn stop(&self)

Signals the processor to stop

Trait Implementations

impl Drop for StreamingInput

fn drop(&mut self)

Executes the destructor for this type.