Struct protoflow_core::InputPort

pub struct InputPort<T: Message> { /* private fields */ }

Implementations

impl<T: Message> InputPort<T>

pub fn new<X: Transport + Default>(system: &System<X>) -> Self

pub fn close(&mut self) -> PortResult<bool>

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

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

Trait Implementations

impl<T: Clone + Message> Clone for InputPort<T>

fn clone(&self) -> InputPort<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Message> Debug for InputPort<T>

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

Formats the value using the given formatter.

impl<T: Message> Display for InputPort<T>

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

Formats the value using the given formatter.

impl<T: Message> From<&InputPort<T>> for PortDescriptor

fn from(port: &InputPort<T>) -> Self

Converts to this type from the input type.

impl<T: Message> MessageReceiver<T> for InputPort<T>

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

Receives a message, blocking until one is available.

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

Tries to receive a message, returning immediately.

impl<T: Message> Port for InputPort<T>

fn id(&self) -> Option<PortID>

A unique identifier for this port.

fn state(&self) -> PortState

The current state of this port.

fn close(&mut self) -> PortResult<bool>

Closes this port, returning immediately.

fn name(&self) -> Option<&str>

The machine-readable name of this port.

fn label(&self) -> Option<&str>

A human-readable label for this port.

fn is_closed(&self) -> bool

Checks whether this port is currently closed.

fn is_open(&self) -> bool

Checks whether this port is currently open.

fn is_connected(&self) -> bool

Checks whether this port is currently connected.