Struct Pipeline 

pub struct Pipeline { /* private fields */ }

Bounded experience pipeline for decoupled collection and training.

Uses a crossbeam bounded channel internally, providing backpressure when the learner falls behind the collector. The capacity controls how many RolloutBatches can be buffered before the sender blocks.

Implementations

impl Pipeline

pub fn new(capacity: usize) -> Self

Create a new pipeline with the given buffer capacity.

Panics

Panics if capacity is zero.

pub fn send(&self, batch: RolloutBatch) -> Result<(), RloxError>

Send a batch into the pipeline (blocks if full).

pub fn try_send(&self, batch: RolloutBatch) -> Result<(), RloxError>

Try to send a batch without blocking. Returns Ok(()) on success, Err with the batch if the channel is full or disconnected.

pub fn recv(&self) -> Result<RolloutBatch, RloxError>

Receive a batch (blocks until one is available).

pub fn try_recv(&self) -> Option<RolloutBatch>

Try to receive a batch without blocking.

pub fn len(&self) -> usize

Number of batches currently buffered in the channel.

pub fn is_empty(&self) -> bool

Whether the channel is currently empty.

pub fn sender(&self) -> Sender<RolloutBatch>

Get a clone of the sender (for use in collector threads).

pub fn receiver(&self) -> Receiver<RolloutBatch>

Get a clone of the receiver (for use in learner threads).