Struct wick_packet::OutgoingPort

pub struct OutgoingPort<T> { /* private fields */ }

Implementations

impl<T> OutgoingPort<T>where T: Serialize,

pub fn new<K: Into<String>>( name: K, channel: FluxChannel<RawPayload, PayloadError> ) -> Self

Trait Implementations

impl<T> Debug for OutgoingPort<T>

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

Formats the value using the given formatter.

impl<T> Port for OutgoingPort<T>where T: Serialize + ConditionallySend,

fn send_packet(&mut self, value: Packet)

fn name(&self) -> &str

fn send_raw_payload(&mut self, value: PacketPayload)

fn open_bracket(&mut self)

fn close_bracket(&mut self)

fn done(&mut self)

fn error(&mut self, err: &str)

impl<T> ValuePort<&T> for OutgoingPort<T>where T: Serialize + ConditionallySend,

fn send(&mut self, value: &T)

fn send_result(&mut self, value: Result<&T, impl Display>)

impl ValuePort<&str> for OutgoingPort<String>

fn send(&mut self, value: &str)

fn send_result(&mut self, value: Result<&str, impl Display>)

impl<T> ValuePort<T> for OutgoingPort<T>where T: Serialize + ConditionallySend,

fn send(&mut self, value: T)

fn send_result(&mut self, value: Result<T, impl Display>)