Struct Session 

pub struct Session { /* private fields */ }

An actor which manages the IPC connection to a remote endpoint.

Trait Implementations

impl Actor for Session

type Context = SessionContext

The execution context type for this actor.

type Error = SessionError

The error type returned by lifecycle hooks and message handlers.

async fn post_start( &mut self, ctx: &mut Self::Context, ) -> Result<(), SessionError>

Invoked after an actor is spawned into the tokio runtime. The actor should be in Starting state.

async fn post_stop( &mut self, _ctx: &mut Self::Context, ) -> Result<(), SessionError>

Invoked after an actor is stopped. The actor should be in Stopped state.

fn pre_start(&mut self, ctx: &mut Self::Context) -> Result<(), Self::Error>

Invoked before an actor is spawned into the tokio runtime. The actor should be in Unstarted state.

fn stopping( &mut self, ctx: &mut Self::Context, ) -> impl Future<Output = Result<Stopping, Self::Error>> + Send

Invoked when an actor is being stopped. The actor should be in Stopping state.

fn start<S>( self, label: S, ) -> Result<(Address<Self>, JoinHandle<()>), Self::Error>

where S: AsRef<str>,

Starts an actor, returns its address and the join handle.

fn create<S, F>( label: S, f: F, ) -> Result<(Address<Self>, JoinHandle<()>), Self::Error>

where S: AsRef<str>, F: FnOnce(&mut Self::Context) -> Result<Self, Self::Error>,

Creates a new actor, starts it and returns its address and the join handle.

impl Handler<BinaryMessage> for Session

type Result = ()

The return type of the handler, which must implement MessageResponse.

async fn handle( &mut self, msg: BinaryMessage, _ctx: &mut <Self as Actor>::Context, ) -> Self::Result

Handles a message.

impl<A> Handler<RemoteCreateActor<A>> for Session

where A: Actor + RemoteSpawnable,

type Result = FutureMessageResult<RemoteCreateActor<A>>

The return type of the handler, which must implement MessageResponse.

async fn handle( &mut self, msg: RemoteCreateActor<A>, _ctx: &mut <Self as Actor>::Context, ) -> Self::Result

Handles a message.

impl<A> Handler<RemoteGetActor<A>> for Session

where A: Actor + RemoteAddressable,

type Result = FutureMessageResult<RemoteGetActor<A>>

The return type of the handler, which must implement MessageResponse.

async fn handle( &mut self, msg: RemoteGetActor<A>, _ctx: &mut <Self as Actor>::Context, ) -> Self::Result

Handles a message.