Struct heph_rt::access::ThreadSafe

pub struct ThreadSafe { /* private fields */ }

Provides access to the thread-safe parts of the runtime.

This implements the Access trait, which is required by various APIs to get access to the runtime.

This is usually a part of the actor::Context, see it for more information.

Implementations

impl ThreadSafe

pub fn spawn_future<Fut>(&mut self, future: Fut, options: FutureOptions)where
    Fut: Future<Output = ()> + Send + Sync + 'static,

Spawn a thread-safe Future.

See RuntimeRef::spawn_future for more documentation.

Trait Implementations

impl Clone for ThreadSafe

fn clone(&self) -> ThreadSafe

Returns a copy of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ThreadSafe

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

Formats the value using the given formatter.

impl<S, NA> Spawn<S, NA, ThreadSafe> for Runtimewhere
    S: Supervisor<NA> + Send + Sync + 'static,
    NA: NewActor<RuntimeAccess = ThreadSafe> + Send + Sync + 'static,
    NA::Actor: Send + Sync + 'static,
    NA::Message: Send,

fn try_spawn(
    &mut self,
    supervisor: S,
    new_actor: NA,
    arg: NA::Argument,
    options: ActorOptions
) -> Result<ActorRef<NA::Message>, NA::Error>where
    S: Supervisor<NA>,
    NA: NewActor<RuntimeAccess = RT>,

Attempts to spawn an actor.

impl<S, NA> Spawn<S, NA, ThreadSafe> for RuntimeRefwhere
    S: Supervisor<NA> + Send + Sync + 'static,
    NA: NewActor<RuntimeAccess = ThreadSafe> + Send + Sync + 'static,
    NA::Actor: Send + Sync + 'static,
    NA::Message: Send,

fn try_spawn(
    &mut self,
    supervisor: S,
    new_actor: NA,
    arg: NA::Argument,
    options: ActorOptions
) -> Result<ActorRef<NA::Message>, NA::Error>where
    S: Supervisor<NA>,
    NA: NewActor<RuntimeAccess = RT>,

Attempts to spawn an actor.

impl<S, NA> Spawn<S, NA, ThreadSafe> for Syncwhere
    S: Supervisor<NA> + Send + Sync + 'static,
    NA: NewActor<RuntimeAccess = ThreadSafe> + Send + Sync + 'static,
    NA::Actor: Send + Sync + 'static,
    NA::Message: Send,

fn try_spawn(
    &mut self,
    supervisor: S,
    new_actor: NA,
    arg: NA::Argument,
    options: ActorOptions
) -> Result<ActorRef<NA::Message>, NA::Error>where
    S: Supervisor<NA>,
    NA: NewActor<RuntimeAccess = RT>,

Attempts to spawn an actor.

impl<S, NA> Spawn<S, NA, ThreadSafe> for ThreadLocalwhere
    S: Supervisor<NA> + Send + Sync + 'static,
    NA: NewActor<RuntimeAccess = ThreadSafe> + Send + Sync + 'static,
    NA::Actor: Send + Sync + 'static,
    NA::Message: Send,

fn try_spawn(
    &mut self,
    supervisor: S,
    new_actor: NA,
    arg: NA::Argument,
    options: ActorOptions
) -> Result<ActorRef<NA::Message>, NA::Error>where
    S: Supervisor<NA>,
    NA: NewActor<RuntimeAccess = RT>,

Attempts to spawn an actor.

impl<S, NA> Spawn<S, NA, ThreadSafe> for ThreadSafewhere
    S: Supervisor<NA> + Send + Sync + 'static,
    NA: NewActor<RuntimeAccess = ThreadSafe> + Send + Sync + 'static,
    NA::Actor: Send + Sync + 'static,
    NA::Message: Send,

fn try_spawn(
    &mut self,
    supervisor: S,
    new_actor: NA,
    arg: NA::Argument,
    options: ActorOptions
) -> Result<ActorRef<NA::Message>, NA::Error>where
    S: Supervisor<NA>,
    NA: NewActor<RuntimeAccess = RT>,

Attempts to spawn an actor.

impl Access for ThreadSafe