Struct RecordingDelivery 

pub struct RecordingDelivery { /* private fields */ }

A NotificationDelivery for tests: records every request it is handed and answers from a script.

Answers Delivered once the script runs out, so RecordingDelivery::new() delivers everything and RecordingDelivery::answering(vec![Retry(..), Retry(..), Delivered]) fails twice first.

Implementations

impl RecordingDelivery

pub fn new() -> Self

A delivery that records requests and delivers all of them.

pub fn answering(outcomes: Vec<DeliveryOutcome>) -> Self

A delivery that answers outcomes in turn, then Delivered.

pub fn always(outcome: DeliveryOutcome) -> Self

A delivery that answers outcome to every request.

pub fn named(self, consumer: impl Into<String>) -> Self

Claim requests under consumer instead of the default name.

pub fn received(&self) -> Vec<PendingNotification>

Every request handed to the delivery so far, in order, redeliveries included.

pub fn calls(&self) -> usize

How many times the delivery was called.

Trait Implementations

impl Clone for RecordingDelivery

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for RecordingDelivery

fn default() -> Self

Returns the “default value” for a type.

impl NotificationDelivery for RecordingDelivery

fn consumer(&self) -> &str

The name this delivery claims requests under in the inbox. Two deliveries that must each handle every request (a mail module and an audit mirror) name themselves apart; a single delivery keeps the default.

fn deliver<'life0, 'life1, 'async_trait>( &'life0 self, notification: &'life1 PendingNotification, ) -> Pin<Box<dyn Future<Output = DeliveryOutcome> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Perform notification.