Struct ProcMesh

pub struct ProcMesh { /* private fields */ }

A mesh of processes.

Implementations

impl ProcMesh

pub async fn allocate( cx: &impl Actor, alloc: Box<dyn Alloc + Send + Sync + 'static>, name: &str, ) -> Result<Self>

Allocate a new ProcMesh from the provided alloc. Allocate does not require an owning actor because references are not owned. Allocate a new ProcMesh from the provided alloc.

Methods from Deref<Target = ProcMeshRef>

pub async fn status(&self, cx: &impl Actor) -> Result<ValueMesh<bool>>

The current statuses of procs in this mesh.

pub async fn actor_states( &self, cx: &impl Actor, name: Name, ) -> Result<ValueMesh<State<ActorState>>>

The supervision events of procs in this mesh.

pub async fn spawn<A: Actor + Referable>( &self, cx: &impl Actor, name: &str, params: &A::Params, ) -> Result<ActorMesh<A>>

where A::Params: RemoteMessage,

Spawn an actor on all of the procs in this mesh, returning a new ActorMesh.

Bounds:

• A: Actor - the actor actually runs inside each proc.
• A: Referable - so we can return typed ActorRef<A>s inside the ActorMesh.
• A::Params: RemoteMessage - spawn parameters must be serializable and routable.

Trait Implementations

impl Debug for ProcMesh

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

Formats the value using the given formatter.

impl Deref for ProcMesh

type Target = ProcMeshRef

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.