Struct hedwig::mock::MockAckToken

pub struct MockAckToken { /* fields omitted */ }

This is supported on test or crate feature mock only.

An acknowledge token associated with a particular message from a MockConsumer.

When nack is called for a particular message’s token, that message will be re-submitted to consumers of the corresponding subscription. Messages otherwise do not have any timeout behavior, so a message is only re-sent to consumers if it is explicitly nack’ed; ack and modify_deadline have no effect

Trait Implementations

impl AcknowledgeToken for MockAckToken

type AckError = Error

Errors returned by ack

type NackError = Error

Errors returned by nack

type ModifyError = Error

Errors returned by modify_deadline

fn ack<'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = Result<(), Self::AckError>> + Send + 'async_trait>> where
    Self: 'async_trait, 

Acknowledge the associated message

fn nack<'async_trait>(
    self
) -> Pin<Box<dyn Future<Output = Result<(), Self::NackError>> + Send + 'async_trait>> where
    Self: 'async_trait, 

Negatively acknowledge the associated message

fn modify_deadline<'life0, 'async_trait>(
    &'life0 mut self,
    _seconds: u32
) -> Pin<Box<dyn Future<Output = Result<(), Self::ModifyError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, 

Change the associated message’s acknowledge deadline to the given number of seconds

impl Debug for MockAckToken

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

Formats the value using the given formatter.