Struct crossbus::context::ContextRunner

pub struct ContextRunner<A>where
    A: Actor,{ /* private fields */ }

Future-oriented runner that drive all tasks into completion

Implementations

impl<A: Actor> ContextRunner<A>

pub fn new(ctx: Context<A>, act: ActorGuard<A>) -> Self

create an instance

pub fn update(&mut self) -> bool

pull new actor futures from context

pub fn is_alive(&self) -> bool

should the runner continue to be alive or exit

pub fn is_blocked(&self) -> bool

if the actor is blocked or not

Trait Implementations

impl<A: Actor> Debug for ContextRunner<A>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<A> Future for ContextRunner<A>where A: Actor,

Safety: no technical guarantee that only one mutable access when mutably borrow ActorGuard<A> in ContextRunner. but so far it is safe to use. Since mutation only happens in poll and its called-functions inside, and at most one mutable access happens there.

type Output = ()

The type of value produced on completion.

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

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<A: Actor> Send for ContextRunner<A>

impl<A: Actor> Sync for ContextRunner<A>