Struct BoundedChannel 

pub struct BoundedChannel<T> { /* private fields */ }

A bounded channel with configurable backpressure handling.

Implementations

impl<T> BoundedChannel<T>

pub fn new(capacity: usize, strategy: BackpressureStrategy) -> Self

Creates a new bounded channel with the given capacity and backpressure strategy.

pub fn send(&self, item: T) -> SynthResult<bool>

Sends an item through the channel.

Returns Ok(true) if the item was sent, Ok(false) if it was dropped, or Err if the channel is closed.

pub fn send_timeout(&self, item: T, timeout: Duration) -> SynthResult<bool>

Sends an item with a timeout.

pub fn recv(&self) -> Option<T>

Receives an item from the channel.

Returns None if the channel is closed and empty.

pub fn recv_timeout(&self, timeout: Duration) -> Option<T>

Receives an item with a timeout.

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

Tries to receive an item without blocking.

pub fn close(&self)

Closes the channel.

pub fn is_closed(&self) -> bool

Returns whether the channel is closed.

pub fn len(&self) -> usize

Returns the current number of items in the buffer.

pub fn is_empty(&self) -> bool

Returns whether the buffer is empty.

pub fn capacity(&self) -> usize

Returns the channel capacity.

pub fn stats(&self) -> ChannelStats

Returns channel statistics.

Trait Implementations

impl<T> Clone for BoundedChannel<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.