Struct Receiver 

pub struct Receiver<T, Codec = Json, const MAX_ITEM_SIZE: usize = remoc::::rch::oneshot::receiver::Receiver::{constant#0}>(/* private fields */);

Receive a value from the associated sender.

Await this future to receive the value.

Implementations

impl<T, Codec, const MAX_ITEM_SIZE: usize> Receiver<T, Codec, MAX_ITEM_SIZE>

where T: DeserializeOwned + Send + 'static, Codec: Codec,

pub fn close(&mut self)

Prevents the associated sender from sending a value.

pub fn try_recv(&mut self) -> Result<T, TryRecvError>

Attempts to receive a value transmitted by the sender.

pub fn max_item_size(&self) -> usize

The maximum item size in bytes.

pub fn set_max_item_size<const NEW_MAX_ITEM_SIZE: usize>( self, ) -> Receiver<T, Codec, NEW_MAX_ITEM_SIZE>

Sets the maximum item size in bytes.

pub fn remote_max_item_size(&self) -> Option<usize>

The maximum item size of the remote sender.

If this is larger than max_item_size sending of oversized items will succeed but receiving will fail with a MaxItemSizeExceeded error.

Trait Implementations

impl<T, Codec, const MAX_ITEM_SIZE: usize> Debug for Receiver<T, Codec, MAX_ITEM_SIZE>

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

Formats the value using the given formatter.

impl<'de, T, Codec, const MAX_ITEM_SIZE: usize> Deserialize<'de> for Receiver<T, Codec, MAX_ITEM_SIZE>

where T: RemoteSend, Codec: Codec,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T, Codec, const MAX_ITEM_SIZE: usize> Future for Receiver<T, Codec, MAX_ITEM_SIZE>

where T: DeserializeOwned + Send + 'static, Codec: Codec,

fn poll( self: Pin<&mut Receiver<T, Codec, MAX_ITEM_SIZE>>, cx: &mut Context<'_>, ) -> Poll<<Receiver<T, Codec, MAX_ITEM_SIZE> as Future>::Output>

Receives the value transmitted by the sender.

type Output = Result<T, RecvError>

The type of value produced on completion.

impl<T, Codec, const MAX_ITEM_SIZE: usize> Serialize for Receiver<T, Codec, MAX_ITEM_SIZE>

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.