Struct apalis_core::job::JobRequestWrapper

pub struct JobRequestWrapper<T>(pub Result<Option<JobRequest<T>>, JobStreamError>);

Expand description

Represents a wrapper for a job produced from streams

Tuple Fields

0: Result<Option<JobRequest<T>>, JobStreamError>

Trait Implementations

Formats the value using the given formatter. Read more

Available on crate feature worker only.

Result type of message

Auto Trait Implementations

Blanket Implementations

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Returns the argument unchanged.

Available on crate feature worker only.

Result of handler

Available on crate feature worker only.

Message handler

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct apalis_core::job::JobRequestWrapper

Tuple Fields

Trait Implementations

Auto Trait Implementations

Blanket Implementations

Struct apalis_core::job::JobRequestWrapper

Tuple Fields

Trait Implementations

impl<T: Debug> Debug for JobRequestWrapper<T>

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

impl<T> Message for JobRequestWrapper<T>

type Result = ()

Auto Trait Implementations

impl<T> !RefUnwindSafe for JobRequestWrapper<T>

impl<T> Send for JobRequestWrapper<T> where T: Send,

impl<T> Sync for JobRequestWrapper<T> where T: Sync,

impl<T> Unpin for JobRequestWrapper<T> where T: Unpin,

impl<T> !UnwindSafe for JobRequestWrapper<T>

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T, W> Handler<JobRequestWrapper<T>> for W where W: 'static + Worker<Job = T>, T: 'static + Job + Serialize + Debug + DeserializeOwned + Send,

type Result = ()

fn handle<'life0, 'async_trait>( &'life0 mut self, job: JobRequestWrapper<T>) -> Pin<Box<dyn Future<Output = <W as Handler<JobRequestWrapper<T>>>::Result> + Send + 'async_trait, Global>> where 'life0: 'async_trait, W: 'async_trait,

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for T where U: From<T>,

fn into(self) -> U

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

impl<T> Send for JobRequestWrapper<T> where
T: Send,

impl<T> Sync for JobRequestWrapper<T> where
T: Sync,

impl<T> Unpin for JobRequestWrapper<T> where
T: Unpin,

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<T, W> Handler<JobRequestWrapper<T>> for W where
W: 'static + Worker<Job = T>,
T: 'static + Job + Serialize + Debug + DeserializeOwned + Send,

fn handle<'life0, 'async_trait>(
&'life0 mut self,
job: JobRequestWrapper<T>
) -> Pin<Box<dyn Future<Output = <W as Handler<JobRequestWrapper<T>>>::Result> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
W: 'async_trait,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,