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
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]
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]
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]
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]
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]
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]
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]
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]
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]
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]
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]
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]
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]
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]
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]
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]
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]
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]
Implementors
impl<C: Consumer + Actor, J: Job<Result = R> + JobHandler<C>, R: Debug + 'static> JobResponse<C, J> for JobFuture<R>
[src]
impl<C: Consumer + Actor, J: Job<Result = R> + JobHandler<C>, R: Debug + 'static> JobResponse<C, J> for JobFuture<R>
[src]