Struct Deduplicator 

pub struct Deduplicator<A: Address, K, T, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = DeduplicatorOutcome<K, T>>>> { /* private fields */ }

Bounded, deterministic first-seen delivery behavior.

A retained key rejects delivery and returns the owned payload. A new key is committed before its delivery is emitted; when retention is full, the oldest key is returned in the result before the new key becomes newest. Duplicate attempts do not refresh retention. Initialization is empty, the fold creates no actors, and it never terminates by policy. The finite FIFO retention window is deliberate Bombay policy and makes the limitation of deduplication explicit: an evicted key can be accepted again. Physical mailbox delivery remains a runtime responsibility. Construction rejects zero capacity and transitions have no panic path.

Implementations

impl<A, K, T, TargetRoute, ReplyRoute> Deduplicator<A, K, T, TargetRoute, ReplyRoute>

where A: Address, K: Clone + Eq, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = DeduplicatorOutcome<K, T>>>,

pub fn new(capacity: usize) -> Result<Self, DeduplicatorConfigError>

Construct empty positive bounded retention.

Errors

Returns DeduplicatorConfigError::ZeroCapacity for zero capacity.

pub fn state(&self) -> DeduplicatorState<K>

Return a snapshot of the complete retention policy state.

Trait Implementations

impl<A, K, T, TargetRoute, ReplyRoute> Behavior for Deduplicator<A, K, T, TargetRoute, ReplyRoute>

where A: Address, K: Clone + Eq, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = DeduplicatorOutcome<K, T>>>, TargetRoute::Sends: SendsFor<User<A, DeduplicatorMessage<K, T, TargetRoute, ReplyRoute>>>, ReplyRoute::Sends: SendsFor<User<A, DeduplicatorMessage<K, T, TargetRoute, ReplyRoute>>>,

type Protocol = Deduplicator<A, K, T, TargetRoute, ReplyRoute>

Stable public communication identity owned by this actor template.

type Event = User<A, <<Deduplicator<A, K, T, TargetRoute, ReplyRoute> as Behavior>::Protocol as Protocol>::Msg>

type Sends = DeliveryOutcomes<<TargetRoute as DeliveryRoute>::Sends, <ReplyRoute as DeliveryRoute>::Sends>

type Ph = Never

type Error = Never

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, T, TargetRoute, ReplyRoute> BehaviorBase for Deduplicator<A, K, T, TargetRoute, ReplyRoute>

where A: Address, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = DeduplicatorOutcome<K, T>>>,

type Base = Deduplicator<A, K, T, TargetRoute, ReplyRoute>

fn base(&self) -> &Self

impl<A, K, T, TargetRoute, ReplyRoute> Protocol for Deduplicator<A, K, T, TargetRoute, ReplyRoute>

where A: Address, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = DeduplicatorOutcome<K, T>>>,

type Addr = A

type Msg = DeduplicatorMessage<K, T, TargetRoute, ReplyRoute>