FsActor

Struct FsActor 

Source
pub struct FsActor {}

Trait Implementations§

Source§

impl Actor for FsActor

Source§

fn name() -> &'static str

Return a debuggable name of the actor
Source§

fn max_anonymous_actors() -> usize

Declare the maximum amount of anonymous actors that a parent actor can spawn. If the maximum amount of anonymous actors are executing, then pause the actor until there is space to spawn another.
Source§

fn mailbox_size() -> usize

The max size of the actors mailbox. The actor will only be able to store a max of the number provided. After the mailbox is full, it will stop accepting new message or apply back pressure and the sender will need to wait for items to be removed from the mailbox.
Source§

fn start(self) -> ActorRef<Self>
where Self: Actor,

Start an actor using a context
Source§

fn on_start(&mut self, _: &mut Ctx<Self>)
where Self: Actor,

Called before transitioning to an [ActorState::Started] state. Good usage is to load data from a database or disk.
Source§

fn pre_run(&mut self, _: &mut Ctx<Self>)

Called right before the handler for the message. Basically before the actors state transitions from a [ActorState::Started] to a [ActorState::Running]. Good usage is to cache data that can not be lost!
Source§

fn post_run(&mut self, _: &mut Ctx<Self>)

Called after the handler for any message has been called. Is called before actor state transitions from a [ActorState::Running] to a [ActorState::Started]. Good usage is logging.
Source§

fn on_stopping(&mut self, _: &mut Ctx<Self>)

Called after transitioning to an [ActorState::Stopping] state. Mainly used to communicate with all child actors that the actor will be shutting down shortly and that they should also finish executing.
Source§

fn on_stopped(&mut self, _: &mut Ctx<Self>)

Called after transitioning to an [ActorState::Stopped] state. Even when this state is reached there could be messages left inside of the mailbox. Users should save an actors data during the Actor::on_end state transition.
Source§

fn on_end(&mut self, _: &mut Ctx<Self>)

Called after clearing out the actors mailbox and after all child actors have been de-initialized. Good time to clean up the actor and save some of it’s state.

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<A> Message for A
where A: Send + Sync + 'static,