Struct ObservePeer 

pub struct ObservePeer<A: Address> {
    pub peer: A,
}

Ask the local interpreter to observe the exact peer incarnation selected at peer when this request is interpreted.

PeerStopped is the pure result protocol. It arrives eventually if a selected live incarnation later terminates, or may arrive immediately when the interpreter has authoritative retained termination for the requested incarnation. Absence from a live-address table is not such authority: an interpreter that can select neither a live incarnation nor retained terminal history must return the complete request with PeerObservationRejection::UnknownAddress rather than fabricate a stop result.

Fields

peer: A

Implementations

impl<A: Address> ObservePeer<A>

pub const fn new(peer: A) -> Self

Trait Implementations

impl<A> ActionItem for ObservePeer<A>

where A: Address + Send,

Acceptance establishes the relationship and leaves unit; its later result is PeerStopped. Name resolution is the only expected rejection, and the request has no prerequisite.

type Custody = (Option<ObservePeer<A>>, Option<<ObservePeer<A> as ActionItem>::Reply>)

type Input<'a> = &'a mut Option<ObservePeer<A>> where Self: 'a

type Reply = ItemSettlement<ObservePeer<A>, <ObservePeer<A> as ActionItem>::Accepted, <ObservePeer<A> as ActionItem>::Rejection, <ObservePeer<A> as ActionItem>::Prerequisite>

type Accepted = ()

type Rejection = PeerObservationRejection

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<A: Clone + Address> Clone for ObservePeer<A>

fn clone(&self) -> ObservePeer<A>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A: Debug + Address> Debug for ObservePeer<A>

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

Formats the value using the given formatter.

impl<A: Address> From<A> for ObservePeer<A>

fn from(peer: A) -> Self

Converts to this type from the input type.

impl<A: Address> InterpreterRequest for ObservePeer<A>

type ReturnToEmitter = ReturnsToEmitter<PeerStopped<A>, Here>

type LogicalProtocols = NoBirthProtocols

impl<A: PartialEq + Address> PartialEq for ObservePeer<A>

fn eq(&self, other: &ObservePeer<A>) -> 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<A: Copy + Address> Copy for ObservePeer<A>

impl<A: Eq + Address> Eq for ObservePeer<A>

impl<A: Address> StructuralPartialEq for ObservePeer<A>