Trait apalis_core::builder::WorkerFactory

pub trait WorkerFactory<J, S> {
    type Worker: Worker<J>;

    // Required method
    fn build(self, service: S) -> Self::Worker;
}

Helper trait for building new Workers from WorkerBuilder

Required Associated Types

type Worker: Worker<J>

The worker to build

Required Methods

fn build(self, service: S) -> Self::Worker

Builds a WorkerFactory using a tower service that can be used to generate new Worker actors using the build method

Arguments

• service - A tower service

Examples

Implementors

impl<J, S, M, Ser, E, Request> WorkerFactory<J, Ser> for WorkerBuilder<J, S, M>where S: Stream<Item = Result<Option<Request>, E>> + Send + 'static + Unpin, J: Job + Send + 'static, M: Layer<Ser>, <M as Layer<Ser>>::Service: Service<Request> + Send + 'static, E: Sync + Send + 'static + Error, Request: Send + HasJobContext, <<M as Layer<Ser>>::Service as Service<Request>>::Future: Send + 'static, Ser: Service<Request>, <Ser as Service<Request>>::Error: Debug, <<M as Layer<Ser>>::Service as Service<Request>>::Error: Debug,

type Worker = ReadyWorker<S, <M as Layer<Ser>>::Service>