Struct IOPort 

pub struct IOPort { /* private fields */ }

IO Port for Bridge layer.

Holds the receiving end of input channel and sending end of output channel. Owned by ClientRunner.

Implementations

impl IOPort

pub fn new( channel_id: ChannelId, buffer_size: usize, ) -> (Self, IOInputHandle, IOOutputHandle)

Creates a new IOPort with associated handles.

Returns a tuple of:

• IOPort: For the Bridge layer (ClientRunner)
• IOInputHandle: For the View layer to send input
• IOOutputHandle: For the View layer to receive output

Arguments

• channel_id - The channel this port belongs to
• buffer_size - Buffer size for the channels

pub fn with_defaults( channel_id: ChannelId, ) -> (Self, IOInputHandle, IOOutputHandle)

Creates a new IOPort with default buffer size.

pub fn channel_id(&self) -> ChannelId

Returns the channel ID.

pub async fn recv(&mut self) -> Option<IOInput>

Receives input from View layer (async, waits for input).

Returns None if all input handles have been dropped.

pub fn try_recv(&mut self) -> Option<IOInput>

Tries to receive input without blocking.

Returns None if no input is available.

pub async fn send(&self, output: IOOutput) -> Result<(), SendError<IOOutput>>

Sends output to View layer.

Errors

Returns error if the output handle has been dropped.

pub fn try_send(&self, output: IOOutput) -> Result<(), TrySendError<IOOutput>>

Tries to send output without blocking.

Errors

Returns error if the channel is full or closed.

pub fn drain_input(&mut self) -> Vec<IOInput>

Drains all available input without blocking.

Useful for batch processing of queued input.

pub fn is_output_closed(&self) -> bool

Returns true if the output channel is closed.

Trait Implementations

impl Debug for IOPort

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

Formats the value using the given formatter.