Trait apalis_core::JobResponse[−][src]

pub trait JobResponse<C: Consumer + Actor, J: Job + JobHandler<C>> {
    fn process(self, tx: Option<OneshotSender<<J as Job>::Result>>);
}

Required methods

fn process(self, tx: Option<OneshotSender<<J as Job>::Result>>)[src]

Loading content...

Implementations on Foreign Types

impl<C, J, R> JobResponse<C, J> for Option<R> where
    C: Consumer + Actor,
    J: Job<Result = Option<R>> + JobHandler<C>,
    R: Debug + 'static, [src]

fn process(self, tx: Option<OneshotSender<Option<R>>>)[src]

impl<C, J, R, E> JobResponse<C, J> for Result<R, E> where
    C: Consumer + Actor,
    J: Job<Result = Result<R, E>> + JobHandler<C>,
    R: Debug + 'static,
    E: Debug + 'static, [src]

fn process(self, tx: Option<OneshotSender<Result<R, E>>>)[src]

impl<C, J> JobResponse<C, J> for () where
    C: Consumer + Actor,
    J: Job<Result = ()> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<()>>)[src]

impl<C, J> JobResponse<C, J> for u8 where
    C: Consumer + Actor,
    J: Job<Result = u8> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<u8>>)[src]

impl<C, J> JobResponse<C, J> for u16 where
    C: Consumer + Actor,
    J: Job<Result = u16> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<u16>>)[src]

impl<C, J> JobResponse<C, J> for u32 where
    C: Consumer + Actor,
    J: Job<Result = u32> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<u32>>)[src]

impl<C, J> JobResponse<C, J> for u64 where
    C: Consumer + Actor,
    J: Job<Result = u64> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<u64>>)[src]

impl<C, J> JobResponse<C, J> for usize where
    C: Consumer + Actor,
    J: Job<Result = usize> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<usize>>)[src]

impl<C, J> JobResponse<C, J> for i8 where
    C: Consumer + Actor,
    J: Job<Result = i8> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<i8>>)[src]

impl<C, J> JobResponse<C, J> for i16 where
    C: Consumer + Actor,
    J: Job<Result = i16> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<i16>>)[src]

impl<C, J> JobResponse<C, J> for i32 where
    C: Consumer + Actor,
    J: Job<Result = i32> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<i32>>)[src]

impl<C, J> JobResponse<C, J> for i64 where
    C: Consumer + Actor,
    J: Job<Result = i64> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<i64>>)[src]

impl<C, J> JobResponse<C, J> for isize where
    C: Consumer + Actor,
    J: Job<Result = isize> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<isize>>)[src]

impl<C, J> JobResponse<C, J> for f32 where
    C: Consumer + Actor,
    J: Job<Result = f32> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<f32>>)[src]

impl<C, J> JobResponse<C, J> for f64 where
    C: Consumer + Actor,
    J: Job<Result = f64> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<f64>>)[src]

impl<C, J> JobResponse<C, J> for String where
    C: Consumer + Actor,
    J: Job<Result = String> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<String>>)[src]

impl<C, J> JobResponse<C, J> for bool where
    C: Consumer + Actor,
    J: Job<Result = bool> + JobHandler<C>, [src]

fn process(self, tx: Option<OneshotSender<bool>>)[src]

Loading content...

Implementors

impl<C: Consumer + Actor, J: Job<Result = R> + JobHandler<C>, R: Debug + 'static> JobResponse<C, J> for JobFuture<R>[src]

fn process(self, tx: Option<OneshotSender<R>>)[src]

Loading content...