Struct Factory 

pub struct Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue>
where
    TKey: JobKey,
    TMsg: Message,
    TWorkerStart: Message,
    TWorker: Actor<Msg = WorkerMessage<TKey, TMsg>, Arguments = WorkerStartContext<TKey, TMsg, TWorkerStart>>,
    TRouter: Router<TKey, TMsg>,
    TQueue: Queue<TKey, TMsg>,
{ /* private fields */ }

Factory definition.

This is a placeholder instance which contains all of the type specifications for the factories properties

Trait Implementations

impl<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue> Actor for Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue>

where TKey: JobKey, TMsg: Message, TWorkerStart: Message, TWorker: Actor<Msg = WorkerMessage<TKey, TMsg>, Arguments = WorkerStartContext<TKey, TMsg, TWorkerStart>>, TRouter: Router<TKey, TMsg>, TQueue: Queue<TKey, TMsg>,

type Msg = FactoryMessage<TKey, TMsg>

The message type for this actor

type State = FactoryState<TKey, TMsg, TWorker, TWorkerStart, TRouter, TQueue>

The type of state this actor manages internally

type Arguments = FactoryArguments<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue>

Initialization arguments

fn pre_start<'life0, 'async_trait>( &'life0 self, myself: ActorRef<FactoryMessage<TKey, TMsg>>, __arg2: <Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue> as Actor>::Arguments, ) -> Pin<Box<dyn Future<Output = Result<<Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue> as Actor>::State, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue>: 'async_trait,

Invoked when an actor is being started by the system.

fn post_start<'life0, 'life1, 'async_trait>( &'life0 self, myself: ActorRef<FactoryMessage<TKey, TMsg>>, state: &'life1 mut <Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue> as Actor>::State, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue>: 'async_trait,

Invoked after an actor has started.

fn post_stop<'life0, 'life1, 'async_trait>( &'life0 self, myself: ActorRef<<Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue> as Actor>::Msg>, state: &'life1 mut <Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue> as Actor>::State, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue>: 'async_trait,

Invoked after an actor has been stopped to perform final cleanup. In the event the actor is terminated with Signal::Kill or has self-panicked, post_stop won’t be called.

fn handle_supervisor_evt<'life0, 'life1, 'async_trait>( &'life0 self, myself: ActorRef<FactoryMessage<TKey, TMsg>>, message: SupervisionEvent, state: &'life1 mut <Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue> as Actor>::State, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue>: 'async_trait,

Handle the incoming supervision event. Unhandled panics will be captured and sent the the supervisor(s). The default supervision behavior is to exit the supervisor on any child exit. To override this behavior, implement this function.

fn handle<'life0, 'life1, 'async_trait>( &'life0 self, myself: ActorRef<FactoryMessage<TKey, TMsg>>, message: FactoryMessage<TKey, TMsg>, state: &'life1 mut <Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue> as Actor>::State, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue>: 'async_trait,

Handle the incoming message from the event processing loop. Unhandled panickes will be captured and sent to the supervisor(s)

fn spawn<'async_trait>( name: Option<String>, handler: Self, startup_args: Self::Arguments, ) -> Pin<Box<dyn Future<Output = Result<(ActorRef<Self::Msg>, JoinHandle<()>), SpawnErr>> + Send + 'async_trait>>

where Self: 'async_trait,

Spawn an actor of this type, which is unsupervised, automatically starting

fn spawn_linked<'async_trait>( name: Option<String>, handler: Self, startup_args: Self::Arguments, supervisor: ActorCell, ) -> Pin<Box<dyn Future<Output = Result<(ActorRef<Self::Msg>, JoinHandle<()>), SpawnErr>> + Send + 'async_trait>>

where Self: 'async_trait,

Spawn an actor of this type with a supervisor, automatically starting the actor

impl<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue> Debug for Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue>

where TKey: Debug + JobKey, TMsg: Debug + Message, TWorkerStart: Debug + Message, TWorker: Debug + Actor<Msg = WorkerMessage<TKey, TMsg>, Arguments = WorkerStartContext<TKey, TMsg, TWorkerStart>>, TRouter: Debug + Router<TKey, TMsg>, TQueue: Debug + Queue<TKey, TMsg>,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue> Default for Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue>

where TKey: JobKey, TMsg: Message, TWorkerStart: Message, TWorker: Actor<Msg = WorkerMessage<TKey, TMsg>, Arguments = WorkerStartContext<TKey, TMsg, TWorkerStart>>, TRouter: Router<TKey, TMsg>, TQueue: Queue<TKey, TMsg>,

fn default() -> Factory<TKey, TMsg, TWorkerStart, TWorker, TRouter, TQueue>

Returns the “default value” for a type.