Struct wasmflow_traits::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 copy 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.