Struct Buffer 

pub struct Buffer<A, T, TargetRoute, ReplyRoute>
where
    A: Address,
    TargetRoute: DeliveryRoute,
    TargetRoute::Protocol: Protocol<Addr = A, Msg = T>,
    ReplyRoute: DeliveryRoute,
    ReplyRoute::Protocol: Protocol<Addr = A, Msg = BufferOutcome<T>>,
{ /* private fields */ }

Bounded FIFO policy behavior over typed actor deliveries.

State is the named BufferState product. Offers below capacity commit ownership and report Accepted. At capacity, OverflowPolicy either returns the new value, or returns the oldest value before accepting the new one. Release moves exactly the oldest value to the destination lane and reports the remaining depth; empty release reports Empty. No payload is silently discarded. Initialization is empty, transitions do not create actors, and the buffer never terminates itself. FIFO and overflow semantics are Bombay policy. Physical mailbox buffering, admission, fairness, and backpressure remain bombay-communication responsibilities. Construction returns BufferConfigError rather than creating an ownership sink. The internal full-queue eviction uses the proven invariant that positive capacity plus the full-offer branch implies a non-empty queue; callers cannot violate that invariant through the public API.

Implementations

impl<A, T, TargetRoute, ReplyRoute> Buffer<A, T, TargetRoute, ReplyRoute>

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

pub fn new(configuration: BufferConfiguration) -> Self

Bind validated policy to an empty buffer actor.

pub const fn state(&self) -> &BufferState<T, ReplyRoute>

Borrow the complete current buffer state.

Trait Implementations

impl<A, T, TargetRoute, ReplyRoute> Behavior for Buffer<A, T, TargetRoute, ReplyRoute>

where A: Address, TargetRoute: DeliveryRoute, TargetRoute::Protocol: Protocol<Addr = A, Msg = T>, ReplyRoute: DeliveryRoute + Clone, ReplyRoute::Protocol: Protocol<Addr = A, Msg = BufferOutcome<T>>, TargetRoute::Sends: SendsFor<User<A, BufferMessage<T, TargetRoute, ReplyRoute>>>, ReplyRoute::Sends: SendsFor<User<A, BufferMessage<T, TargetRoute, ReplyRoute>>>,

type Protocol = Buffer<A, T, TargetRoute, ReplyRoute>

Stable public communication identity owned by this actor template.

type Event = User<A, <<Buffer<A, 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, T, TargetRoute, ReplyRoute> BehaviorBase for Buffer<A, T, TargetRoute, ReplyRoute>

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

type Base = Buffer<A, T, TargetRoute, ReplyRoute>

fn base(&self) -> &Self

impl<A, T, TargetRoute, ReplyRoute> Protocol for Buffer<A, T, TargetRoute, ReplyRoute>

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

type Addr = A

type Msg = BufferMessage<T, TargetRoute, ReplyRoute>