Struct PortChannel 

pub struct PortChannel {
    pub name: String,
    /* private fields */
}

A PortChannel wraps an unbounded channel with a port name.

Fields

name: String

Port name.

Implementations

impl PortChannel

pub fn new<T: AsRef<str>>(name: T) -> Self

Constructor for a PortChannel.

pub fn open(&mut self) -> UnboundedReceiverStream<PacketWrapper>

Initialize the PortChannel and return a receiver.

pub fn close(&mut self)

Drop the incoming channel, closing the upstream.

pub fn is_closed(&self) -> bool

Returns true if the port still has an active upstream.

pub fn send( &self, msg: PacketWrapper, ) -> Result<(), Box<dyn Error + Send + Sync>>

Send a messages to the channel.

pub fn merge_all(buffer: &mut [&mut PortChannel]) -> PacketStream

Merge a list of PortChannels into a TransportStream.

Trait Implementations

impl Clone for PortChannel

fn clone(&self) -> PortChannel

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PortChannel

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

Formats the value using the given formatter.