Struct near_async::actix_wrapper::SyncActixWrapper

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

Implementations

impl<T> SyncActixWrapper<T>

pub fn new(actor: T) -> Self

Trait Implementations

impl<T> Actor for SyncActixWrapper<T>

where T: Unpin + 'static,

type Context = SyncContext<SyncActixWrapper<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.

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

where Self: Actor, T: Handler<M>, M: Message, <M as Message>::Result: MessageResponse<SyncActixWrapper<T>, WithSpanContext<M>>,

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.