Trait crossbus::blocker::Blocking

pub trait Blocking<A>where
    A: Actor,{
    // Provided methods
    fn started(&mut self, _: &mut Context<A>) { ... }
    fn state(&mut self, _: &mut Context<A>) -> BlockingState { ... }
    fn aborted(&mut self, _: &mut Context<A>) { ... }
    fn finished(&mut self, _: &mut Context<A>) { ... }
}

An abstraction for Actor’s blocking routine

NOTE that any new message sent to this actor will be REJECTED when the actor got any new Blcoker.

Blocker is not recoverable once gets aborted

Provided Methods

fn started(&mut self, _: &mut Context<A>)

called before the blocker get started

fn state(&mut self, _: &mut Context<A>) -> BlockingState

Runtime control of the Blcoker to abort the actor.

Real-Time control or more elaborated execution could be achieved right here

fn aborted(&mut self, _: &mut Context<A>)

called before the blocker get aborted

fn finished(&mut self, _: &mut Context<A>)

called after the blocker successfully finished

Implementors