Struct crossbus::blocker::Blocker

pub struct Blocker<A> { /* private fields */ }

block the actor (or make the actor waiting) until some condition in block is satisfied

Once a new Blocker comes, it will block the actor immediately and reject any incoming messages.

Implementations

impl<A: Actor> Blocker<A>

pub fn new<F>(fut: F) -> Selfwhere F: Future<A, Output = ()> + 'static,

create an instance

pub fn handle(&self) -> Handle

get the handle

pub fn state(&self) -> BlockerState

get the state

pub fn set_state(&mut self, state: BlockerState)

set the state

pub fn from_duration<T: Timing + 'static>(dur: Duration) -> Self

Available on crate feature time only.

block the actor with specified duration

feature time must be enabled and the Timing implementation is required with which the actor can know the time

Trait Implementations

impl<A> Future<A> for Blocker<A>where A: Actor + Blocking<A>,

type Output = ()

the returned type of value when the future polled successfully

fn poll( self: Pin<&mut Self>, act: &mut A, ctx: &mut Context<A>, cx: &mut CoreContext<'_> ) -> Poll<()>

fn downcast_ref(&self) -> Option<&dyn Any>

fn downcast_mut(self: Pin<&mut Self>) -> Option<Pin<&mut dyn Any>>