Struct Task 

pub struct Task<A, R, Route>
where
    A: Address,
    Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = TaskResult<R>>>,
{ /* private fields */ }

One-result terminal behavior template.

State is exactly TaskState::Pending, Completed, or Cancelled. Pending completion commits Completed, emits one typed owned result, and requests normal stop in the same Actions. Pending cancellation commits Cancelled, emits one cancellation fact, and requests normal stop. A universal Driver therefore accepts no later mailbox turn; direct misuse of the pure fold still produces a typed TaskError and returns any result ownership. Initialization is empty. Completion is an application/Bombay construction over actor communication and behavior-requested termination, not a new actor-model primitive. Typed delivery and terminal publication are interpreted by Bombay Communication and Observe. No method has a semantic panic condition.

Implementations

impl<A, R, Route> Task<A, R, Route>

where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = TaskResult<R>>>,

pub const fn new() -> Self

Construct a pending task definition.

pub const fn state(&self) -> TaskState

Current exhaustive terminal state.

Trait Implementations

impl<A, R, Route> Behavior for Task<A, R, Route>

where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = TaskResult<R>>>, Route::Sends: SendsFor<User<A, TaskMessage<R, Route>>>,

type Protocol = Task<A, R, Route>

Stable public communication identity owned by this actor template.

type Event = User<A, <<Task<A, R, Route> as Behavior>::Protocol as Protocol>::Msg>

type Sends = <Route as DeliveryRoute>::Sends

type Ph = Never

type Error = TaskError<R, 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, R, Route> BehaviorBase for Task<A, R, Route>

where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = TaskResult<R>>>,

type Base = Task<A, R, Route>

fn base(&self) -> &Self

impl<A, R, Route> Default for Task<A, R, Route>

where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = TaskResult<R>>>,

fn default() -> Self

Returns the “default value” for a type.

impl<A, R, Route> Protocol for Task<A, R, Route>

where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = TaskResult<R>>>,

type Addr = A

type Msg = TaskMessage<R, Route>