Struct Correlator 

pub struct Correlator<A: Address, K, V, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = CorrelationResult<K, V>>>> { /* private fields */ }

Deterministic keyed request/result lifecycle behavior.

Each key is exactly pending, completed, or cancelled. Begin owns the reply recipient. Resolve atomically marks a pending key completed and emits one typed result; Cancel marks it cancelled and emits one typed cancellation. Terminal keys are retained, making duplicate and stale input explicit rather than indistinguishable from never-seen input. Reopening and retention expiry require a separate explicit policy and are not inferred from time or key reuse. Initialization is empty and the behavior does not terminate itself. These lifecycle and retention choices are Bombay policy; delivery remains an Address/Communication capability. No method has a semantic panic condition.

Implementations

impl<A, K, V, Route> Correlator<A, K, V, Route>

where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = CorrelationResult<K, V>>>,

pub const fn new() -> Self

Construct an empty correlator definition.

pub fn states(&self) -> &[CorrelationState<K, Route>]

Borrow every retained lifecycle in first-begin order.

Trait Implementations

impl<A, K, V, Route> Behavior for Correlator<A, K, V, Route>

where A: Address, K: Clone + Eq, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = CorrelationResult<K, V>>> + Clone, Route::Sends: SendsFor<User<A, CorrelatorMessage<K, V, Route>>>,

type Protocol = Correlator<A, K, V, Route>

Stable public communication identity owned by this actor template.

type Event = User<A, <<Correlator<A, K, V, Route> as Behavior>::Protocol as Protocol>::Msg>

type Sends = <Route as DeliveryRoute>::Sends

type Ph = Never

type Error = CorrelatorError<K, V, Route>

type Birth = NoBirths

fn transition( &mut self, _: ActiveTurn, event: Self::Event, ) -> BehaviorActed<Self>

Fold exactly one event into explicit actions and the next behavior.

fn init( &mut self, _turn: InitializationTurn, ) -> Result<Actions<<Self::Protocol as Protocol>::Addr, Self::Ph, Self::Sends, Self::Birth>, Self::Error>

where Self: Sized,

Produce initialization actions before the first event is accepted.

fn layer<L>(self, layer: L) -> <L as BehaviorLayer<Self>>::Output

where Self: Sized, L: BehaviorLayer<Self>,

Apply one statically dispatched construction layer.

impl<A, K, V, Route> BehaviorBase for Correlator<A, K, V, Route>

where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = CorrelationResult<K, V>>>,

type Base = Correlator<A, K, V, Route>

fn base(&self) -> &Self

impl<A, K, V, Route> Default for Correlator<A, K, V, Route>

where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = CorrelationResult<K, V>>>,

fn default() -> Self

Returns the “default value” for a type.

impl<A, K, V, Route> Protocol for Correlator<A, K, V, Route>

where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = CorrelationResult<K, V>>>,

type Addr = A

type Msg = CorrelatorMessage<K, V, Route>