Struct EstablishedDelivery 

pub struct EstablishedDelivery<P>
where
    P: Protocol,
    P::Addr: RecipientAddress,
{
    pub to: EstablishedRecipient<P>,
    pub message: P::Msg,
}

One pure communication to an exact installed incarnation.

Unlike Delivery, this effect carries the runtime-issued endpoint and requires no address-to-endpoint resolution. Constructing it remains pure; only an explicit crate::InterpretItem implementation for this exact delivery type can perform the communication.

Exact endpoints remain protocol-indexed even when two protocols share an address namespace and message type:

#[derive(Clone, Copy, PartialEq, Eq)]
struct RuntimeAddr(u64);
impl behavior::Address for RuntimeAddr { type Nonce = u64; }
struct Endpoint<P>(core::marker::PhantomData<fn() -> P>);
impl<P> Clone for Endpoint<P> {
    fn clone(&self) -> Self { Self(core::marker::PhantomData) }
}
impl behavior::RecipientAddress for RuntimeAddr {
    type Established<P> = Endpoint<P> where P: behavior::Protocol<Addr = Self>;
}
struct Queue;
struct Worker;
impl behavior::Protocol for Queue { type Addr = RuntimeAddr; type Msg = u8; }
impl behavior::Protocol for Worker { type Addr = RuntimeAddr; type Msg = u8; }
let worker = behavior::EstablishedRecipient::<Worker>::issued(Endpoint(core::marker::PhantomData));
let _: behavior::EstablishedDelivery<Queue> = behavior::EstablishedDelivery::new(worker, 7);

Fields

to: EstablishedRecipient<P>

message: P::Msg

Implementations

impl<P> EstablishedDelivery<P>

where P: Protocol, P::Addr: RecipientAddress,

pub const fn new(to: EstablishedRecipient<P>, message: P::Msg) -> Self

Trait Implementations

impl<P> ActionItem for EstablishedDelivery<P>

where P: Protocol, P::Addr: RecipientAddress, <P::Addr as RecipientAddress>::Established<P>: Send, P::Msg: Send,

type Custody = (Option<EstablishedDelivery<P>>, Option<<EstablishedDelivery<P> as ActionItem>::Reply>)

type Input<'a> = &'a mut Option<EstablishedDelivery<P>> where Self: 'a

type Reply = ItemSettlement<EstablishedDelivery<P>, <EstablishedDelivery<P> as ActionItem>::Accepted, <EstablishedDelivery<P> as ActionItem>::Rejection, <EstablishedDelivery<P> as ActionItem>::Prerequisite>

type Accepted = ()

type Rejection = ExactDeliveryReason

type Prerequisite = Never

fn prepare_interpretation( progress: &mut Option<InterpretationProgress<Self, Self::Custody, Self::Reply>>, )

fn interpretation_input<'a>( custody: &'a mut Self::Custody, ) -> Option<(Self::Input<'a>, &'a mut Option<Self::Reply>)>

where Self: 'a,

fn finish_interpretation( progress: &mut Option<InterpretationProgress<Self, Self::Custody, Self::Reply>>, )

fn retain_accepted(_: Self::Accepted) -> Option<Self::Accepted>

Keep an accepted value only while it still carries terminal custody.

impl<P> Clone for EstablishedDelivery<P>

where P: Protocol, P::Addr: RecipientAddress, P::Msg: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P> Debug for EstablishedDelivery<P>

where P: Protocol, P::Addr: RecipientAddress, EstablishedRecipient<P>: Debug, P::Msg: Debug,

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

Formats the value using the given formatter.

impl<P> PartialEq for EstablishedDelivery<P>

where P: Protocol, P::Addr: RecipientAddress, EstablishedRecipient<P>: PartialEq, P::Msg: PartialEq,

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<P> Eq for EstablishedDelivery<P>

where P: Protocol, P::Addr: RecipientAddress, EstablishedRecipient<P>: Eq, P::Msg: Eq,