Struct apalis_core::worker::ready::ReadyWorker

pub struct ReadyWorker<Stream, Service> { /* private fields */ }

A worker that is ready to consume jobs

Trait Implementations

impl<Stream, Service> Debug for ReadyWorker<Stream, Service>

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

Formats the value using the given formatter.

impl<Strm: Unpin + Send + Stream<Item = Result<Option<Req>, E>> + 'static, Serv: Service<Req, Future = Fut> + Send + 'static, J: Job + 'static, E: 'static + Send + Error + Sync, Req: Send + HasJobContext, Fut: Future + Send + 'static> Worker<J> for ReadyWorker<Strm, Serv>where <Serv as Service<Req>>::Error: Debug,

type Service = Serv

The tower service type that this worker will use to execute jobs.

type Source = Strm

The source type that this worker will use to receive jobs.

fn id(&self) -> WorkerId

A worker must be identifiable and unique

fn start<'async_trait, Exec>( self, ctx: WorkerContext<Exec> ) -> Pin<Box<dyn Future<Output = Result<(), WorkerError>> + Send + 'async_trait>>where Exec: 'async_trait + Executor + Send + Sync + 'static, Self: 'async_trait,

Starts the worker, taking ownership of self and the provided ctx.