Struct Rx 

pub struct Rx<T, const N: usize = 16> { /* private fields */ }

Receiver handle: “I receive”. The holder of an Rx<T> receives items of type T.

In method args, the handler holds it (handler receives ← caller).

Wire encoding is always unit (()), with channel IDs carried exclusively in Message::Request.channels.

Implementations

impl<T, const N: usize> Rx<T, N>

pub fn unbound() -> Self

Create a standalone unbound Rx (used by deserialization).

pub fn is_bound(&self) -> bool

pub fn has_core(&self) -> bool

Check if this Rx is part of a channel() pair (has a shared core).

pub async fn recv(&mut self) -> Result<Option<SelfRef<T>>, RxError>

where T: Facet<'static>,

Trait Implementations

impl<'ʄ, T, const N: usize> Facet<'ʄ> for Rx<T, N>

where T: Facet<'ʄ>,

const SHAPE: &'static Shape

The shape of this type, including: whether it’s a Struct, an Enum, something else?

impl<T, const N: usize> TryFrom<&Rx<T, N>> for ()

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(_value: &Rx<T, N>) -> Result<Self, Self::Error>

Performs the conversion.

impl<T, const N: usize> TryFrom<()> for Rx<T, N>

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(_value: ()) -> Result<Self, Self::Error>

Performs the conversion.