Struct DoActor 

pub struct DoActor<A: Actor> {
    pub actor: A,
    pub context: A::Context,
    pub failures: Failures,
}

Fields

actor: A

context: A::Context

failures: Failures

Implementations

impl<A: Actor> DoActor<A>

pub fn new(actor: A) -> Self

where A::Context: Default,

Trait Implementations

impl<A: Actor> InteractiveRuntime for DoActor<A>

type Context = <A as Actor>::Context

Type of the composable block’s contenxt.

fn address(&self) -> <Self::Context as Context>::Address

impl<A: Actor> InteractiveTask<A> for DoActor<A>

fn spawn_connected(self) -> <Self::Context as Context>::Address

impl<A: Actor> Runtime for DoActor<A>

fn get_interruptor(&mut self) -> Interruptor

Used by a lifetime tracker of the supervisor to stop it. It’s the separate type that wraps address made by a runtime.

fn routine<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl<A: Actor> Task<A> for DoActor<A>

fn spawn(self) -> TaskHandle<T>

fn run<'async_trait>( self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: Send + 'async_trait,