Struct FifoPool 

pub struct FifoPool<Role, W, P, Source, DiagnosticRoute, Job, WorkerResult>
where
    W: Behavior,
    BehaviorAddr<W>: EndpointAddress,
{ /* private fields */ }

A direct-worker FIFO pool with one bounded global backlog.

Trait Implementations

impl<Role, W, P, Source, Diagnostics, Job, WorkerResult> Behavior for FifoPool<Role, W, P, Source, Diagnostics, Job, WorkerResult>

where Role: Eq + Send + Sync, W: Behavior + BehaviorBase + Send, W::Protocol: Protocol<Msg = Assignment<Job>>, W::Sends: CompletesAssignments<WorkerResult = WorkerResult>, P: ActivationPlan, Source: WorkerSource<Role, W, P>, Diagnostics: DiagnosticRoute<FifoDiagnostic<Role, W, P, Source, Job, WorkerResult>> + Clone, BehaviorAddr<W>: EndpointAddress, <BehaviorAddr<W> as Address>::Nonce: Send, <BehaviorAddr<W> as EndpointAddress>::Established<W::Protocol>: Send, StopOnShutdown<W>: Behavior<Protocol = W::Protocol, Error = W::Error, Ph = W::Ph, Birth = W::Birth>, <StopOnShutdown<W> as Behavior>::Event: InjectEvent<ShutdownRequested, Here>, Job: Clone + Send, WorkerResult: Send,

type Protocol = MessageProtocol<<<W as Behavior>::Protocol as Protocol>::Addr, FifoCommand<<<W as Behavior>::Protocol as Protocol>::Addr, Role, Job, WorkerResult>>

Stable public communication identity owned by this actor template.

type Event = FifoEvent<Role, W, P, Job, WorkerResult, SettledItem<PrepareWorkers<Source, Role, W, P>, ItemSettlement<PrepareWorkers<Source, Role, W, P>, <PrepareWorkers<Source, Role, W, P> as ActionItem>::Accepted, <PrepareWorkers<Source, Role, W, P> as ActionItem>::Rejection, <PrepareWorkers<Source, Role, W, P> as ActionItem>::Prerequisite>>, WorkerPreparation<Source, Role, W, P>>

type Sends = FifoRequests<InterpreterRequests<ObserveChild<<W as Behavior>::Protocol, ChildHead>>, InterpreterRequests<InitializeWorker<W, P>>, InterpreterRequests<BeginActivation<W, P>>, <ReplyRoute<MessageProtocol<<<W as Behavior>::Protocol as Protocol>::Addr, FifoOutcome<Role, Job, WorkerResult>>> as DeliveryRoute>::Sends, SourceActions<AssignWorker<<W as Behavior>::Protocol, Job>>, SourceActions<PrepareWorkers<Source, Role, W, P>>, SourceActions<ScheduleAfter>, InterpreterRequests<ShutdownEstablished<StopOnShutdown<W>, Here>>, InterpreterRequests<DiagnosticAction<Diagnostics, FifoDiagnostic<Role, W, P, Source, Job, WorkerResult>>>>

type Ph = Never

type Error = FifoError

type Birth = Births<StopOnShutdown<W>>

fn init(&mut self, _: InitializationTurn) -> BehaviorActed<Self>

Produce initialization actions before the first event is accepted.

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

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

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

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

Apply one statically dispatched construction layer.

impl<Role, W, P, Source, DiagnosticRoute, Job, WorkerResult> BehaviorBase for FifoPool<Role, W, P, Source, DiagnosticRoute, Job, WorkerResult>

where Role: Send + Sync, W: Behavior + Send, W::Protocol: Protocol<Msg = Assignment<Job>>, W::Sends: CompletesAssignments<WorkerResult = WorkerResult>, P: ActivationPlan, Source: WorkerSource<Role, W, P>, BehaviorAddr<W>: EndpointAddress, Job: Send,

type Base = FifoPool<Role, W, P, Source, DiagnosticRoute, Job, WorkerResult>

fn base(&self) -> &Self::Base