Struct ActixWrapper 

pub struct ActixWrapper<T> { /* private fields */ }

Wrapper on top of a generic actor to make it implement actix::Actor trait. The wrapped actor should implement the Handler trait for all the messages it would like to handle. ActixWrapper is then used to create an actix actor that implements the CanSend trait.

Implementations

impl<T> ActixWrapper<T>

pub fn new(actor: T) -> Self

Trait Implementations

impl<T> Actor for ActixWrapper<T>

where T: Actor + Unpin + 'static,

type Context = Context<ActixWrapper<T>>

Actor execution context type

fn started(&mut self, ctx: &mut Self::Context)

Called when an actor gets polled the first time.

fn stopping(&mut self, ctx: &mut Self::Context) -> Running

Called after an actor is in Actor::Stopping state.

fn stopped(&mut self, ctx: &mut Self::Context)

Called after an actor is stopped.

fn start(self) -> Addr<Self>

where Self: Actor<Context = Context<Self>>,

Start a new asynchronous actor, returning its address.

fn start_in_arbiter<F>(wrk: &ArbiterHandle, f: F) -> Addr<Self>

where Self: Actor<Context = Context<Self>>, F: FnOnce(&mut Context<Self>) -> Self + Send + 'static,

Start new actor in arbiter’s thread.

fn create<F>(f: F) -> Addr<Self>

where Self: Actor<Context = Context<Self>>, F: FnOnce(&mut Context<Self>) -> Self,

Start a new asynchronous actor given a Context.

impl<T> Deref for ActixWrapper<T>

type Target = T

The resulting type after dereferencing.

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

Dereferences the value.

impl<T> DerefMut for ActixWrapper<T>

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

Mutably dereferences the value.

impl<M, T> Handler<WithSpanContext<M>> for ActixWrapper<T>

where Self: Actor, Self::Context: DelayedActionRunner<T>, T: HandlerWithContext<M>, M: Message, <M as Message>::Result: MessageResponse<ActixWrapper<T>, WithSpanContext<M>> + Send,

type Result = <M as Message>::Result

The type of value that this handler will return.

fn handle( &mut self, msg: WithSpanContext<M>, ctx: &mut Self::Context, ) -> Self::Result

This method is called for every message received by this actor.