Struct CancelObservation 

pub struct CancelObservation<P: Protocol> { /* private fields */ }

One affine attempt to cancel the exact accepted relationship.

Cancellation acknowledgements require their own typed report ingress.

fn accepts<Event, Sends: behavior::SendsFor<Event>>() {}

pub fn cancellation_acknowledgement<P>() where P: behavior::Protocol, P::Addr: behavior::RecipientAddress {
    accepts::<behavior::EventLayer<behavior_actors::EstablishedObservation<P>, behavior::User<P::Addr, P::Msg>>, behavior::InterpreterRequests<behavior_actors::CancelObservation<P>>>();
}

fn accepts<Event, Sends: behavior::SendsFor<Event>>() {}

pub fn cancellation_acknowledgement<P>() where P: behavior::Protocol, P::Addr: behavior::RecipientAddress {
    accepts::<behavior::User<P::Addr, P::Msg>, behavior::InterpreterRequests<behavior_actors::CancelObservation<P>>>();
}

Implementations

impl<P: Protocol> CancelObservation<P>

pub fn new(authority: ObservationAuthority<P>) -> Self

pub fn id(&self) -> ObservationId

pub fn relationship(&self) -> &ObservationRelationship<P>

pub fn into_authority(self) -> ObservationAuthority<P>

Recover the same permission from an unconsumed cancellation request.

pub fn into_relationship(self) -> ObservationRelationship<P>

Consume permission and retain the exact non-authorizing receipt.

pub fn interpret<I>(self, interpreter: &mut I) -> I::Output

where P::Addr: RecipientAddress, I: InterpretEstablishedObservation<P>,

pub fn settle<I>( self, interpreter: &mut I, ) -> ItemSettlement<Self, (), Never, Never>

where P::Addr: RecipientAddress, I: InterpretEstablishedObservation<P, Output = ()>,

Trait Implementations

impl<P: Protocol> ActionItem for CancelObservation<P>

where P::Addr: RecipientAddress,

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

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

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

type Accepted = ()

type Rejection = Never

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: Protocol> InterpreterRequest for CancelObservation<P>

where P::Addr: RecipientAddress,

type ReturnToEmitter = ReturnsToEmitter<EstablishedObservation<P>, Here>

type LogicalProtocols = NoBirthProtocols