Struct SampleSender 

pub struct SampleSender { /* private fields */ }

A clonable sender handle for streaming Samples into the training loop.

Wraps a tokio::sync::mpsc::Sender<Sample> and maps channel errors to IrithyllError::ChannelClosed. Clone this freely to feed samples from multiple async tasks.

Example

sender.send(Sample::new(vec![1.0, 2.0], 3.0)).await?;

Implementations

impl SampleSender

pub async fn send(&self, sample: Sample) -> Result<()>

Send a single sample into the training channel.

Awaits if the channel is full (backpressure). Returns IrithyllError::ChannelClosed if the receiver has been dropped.

pub async fn send_batch(&self, samples: Vec<Sample>) -> Result<()>

Send a batch of samples sequentially into the training channel.

Each sample is sent in order; backpressure applies per-sample. Returns IrithyllError::ChannelClosed if the receiver is dropped before all samples are sent.

pub fn is_closed(&self) -> bool

Returns true if the receiver has been dropped.

Trait Implementations

impl Clone for SampleSender

fn clone(&self) -> SampleSender

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SampleSender

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.