Struct SupervisorSession 

pub struct SupervisorSession<S: Supervisor> { /* private fields */ }

Implementations

impl<S: Supervisor> SupervisorSession<S>

pub fn spawn_actor<A>( &mut self, input: A, group: S::GroupBy, ) -> <A::Context as Context>::Address

where A: Agent, A::Context: Default, S: Supervisor<Context = SupervisorSession<S>>,

impl<S> SupervisorSession<S>

where S: Supervisor, S::Context: SupervisorContext<S>,

pub fn spawn_runtime<B>( &mut self, trackable: B, group: S::GroupBy, ) -> <B::Context as Context>::Address

where B: InteractiveRuntime,

pub fn spawn_trackable<B>(&mut self, trackable: B, group: S::GroupBy)

where B: Runtime,

Methods from Deref<Target = AgentSession<S>>

pub fn joint(&mut self) -> &mut AddressJoint<T>

pub fn do_next(&mut self, next_state: Next<T>)

Methods from Deref<Target = Address<T>>

pub fn send(&self, msg: impl MessageFor<A>) -> Result<(), Error>

pub async fn join(&mut self) -> Result<<A as Agent>::Output, Error>

pub fn event<E>(&self, event: E) -> Result<(), Error>

where T: OnEvent<E>, E: Send + 'static,

pub fn interrupt(&self) -> Result<(), Error>

Trait Implementations

impl<S: Supervisor> AgentContext<S> for SupervisorSession<S>

fn session(&mut self) -> &mut AgentSession<S>

impl<S: Supervisor> Context for SupervisorSession<S>

type Address = Address<S>

An address to interact with the context.

fn address(&self) -> &Self::Address

A reference to an address.

impl<S: Supervisor> Default for SupervisorSession<S>

fn default() -> Self

Returns the “default value” for a type.

impl<S: Supervisor> Deref for SupervisorSession<S>

type Target = AgentSession<S>

The resulting type after dereferencing.

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

Dereferences the value.

impl<S: Supervisor> DerefMut for SupervisorSession<S>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<S: Supervisor> ManagedContext for SupervisorSession<S>

fn controller(&mut self) -> &mut Controller

fn shutdown(&mut self)

Marks a context as interrupted.

impl<S: Supervisor> SupervisorContext<S> for SupervisorSession<S>

fn session(&mut self) -> &mut SupervisorSession<S>