Struct overclock::core::Runtime

pub struct Runtime<H> { /* private fields */ }

Overclock runtime, spawn the root actor, and server (if enabled)

Implementations

impl<H> Runtime<H>where
    H: Clone + Shutdown,

pub async fn new<T, A>(root_dir: T, child: A) -> ActorResult<Self>where
    A: 'static + ChannelBuilder<<A as Actor<NullSupervisor>>::Channel> + Actor<NullSupervisor>,
    T: Into<Option<String>>,
    <A as Actor<NullSupervisor>>::Channel: Channel<Handle = H>,
    H: Shutdown + Clone,

Create and spawn runtime with null supervisor handle

pub async fn with_supervisor<T, A, S>(
    dir: T,
    child: A,
    supervisor: S
) -> ActorResult<Self>where
    A: 'static + ChannelBuilder<<A as Actor<S>>::Channel> + Actor<S>,
    T: Into<Option<String>>,
    <A as Actor<S>>::Channel: Channel<Handle = H>,
    S: SupHandle<A>,
    H: Shutdown + Clone,

Create new runtime with provided supervisor handle

pub fn handle(&self) -> &H

Returns immutable reference to the root actor

pub fn handle_mut(&mut self) -> &mut H

Returns mutable reference to the root actor

pub async fn block_on(self) -> ActorResult<()>

Block on the runtime till it shutdown gracefully