Struct Sender 

pub struct Sender<T, Codec = Json>(/* private fields */);

Sends a value to the associated receiver.

Implementations

impl<T, Codec> Sender<T, Codec>

where T: RemoteSend, Codec: Codec,

pub fn send(self, value: T) -> Result<(), SendError<T>>

Sends a value over this channel.

pub async fn closed(&self)

Completes when the receiver has been closed, dropped or the connection failed.

Use closed_reason to obtain the cause for closure.

pub fn closed_reason(&self) -> Option<ClosedReason>

Returns the reason for why the channel has been closed.

Returns None if the channel is not closed.

pub fn is_closed(&self) -> bool

Returns whether the receiver has been closed, dropped or the connection failed.

Use closed_reason to obtain the cause for closure.

pub fn max_item_size(&self) -> usize

The maximum allowed item size in bytes.

pub fn set_max_item_size(&mut self, max_item_size: usize)

Sets the maximum allowed item size in bytes.

Trait Implementations

impl<T, Codec> Debug for Sender<T, Codec>

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

Formats the value using the given formatter.

impl<'de, T, Codec> Deserialize<'de> for Sender<T, Codec>

where T: RemoteSend, Codec: Codec,

fn deserialize<__D>( __deserializer: __D, ) -> Result<Sender<T, Codec>, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T, Codec> Serialize for Sender<T, Codec>

where T: RemoteSend, Codec: Codec,

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.