Struct AsyncChannel 

pub struct AsyncChannel { /* private fields */ }

Lock-free ring buffer for async messages

Implementations

impl AsyncChannel

pub fn new(id: u64, owner: ProcessId, capacity: usize) -> Self

Create a new async channel

pub fn send_async(&self, msg: Message) -> Result<()>

Send a message without blocking

pub fn receive_async(&self) -> Result<Message>

Receive a message without blocking

pub fn poll(&self, timeout_ns: u64) -> Result<Option<Message>>

Poll for messages with timeout

pub fn subscribe(&self, pid: ProcessId) -> Result<()>

Subscribe to channel notifications

pub fn get_stats(&self) -> AsyncChannelStats

Get channel statistics

pub fn close(&self)

Close the channel