Struct DummyProducer 

pub struct DummyProducer { /* private fields */ }

A Producer that records everything it is given, for assertions in tests.

Cloning shares the same buffer, so a clone can be handed to an InventoryTracker while the original is used to read back what was emitted.

Implementations

impl DummyProducer

pub fn raw(&self) -> Vec<SentMessage>

Returns the raw messages sent so far, in order.

pub fn records(&self) -> Vec<InventoryRecord>

Returns the records sent so far, deserialized, in order.

pub fn clear(&self)

Discards everything sent so far.

Trait Implementations

impl Clone for DummyProducer

fn clone(&self) -> DummyProducer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DummyProducer

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

Formats the value using the given formatter.

impl Default for DummyProducer

fn default() -> DummyProducer

Returns the “default value” for a type.

impl Producer for DummyProducer

type Error = Infallible

What can go wrong when sending.

fn send(&self, key: &[u8], payload: Vec<u8>) -> Result<(), Self::Error>

Enqueues one record.

fn join_blocking(&self, _timeout: Duration) -> Result<(), Self::Error>

Blocks until enqueued records have been delivered, or timeout elapses.

fn join( &self, timeout: Duration, ) -> impl Future<Output = Result<(), Self::Error>> + Send + use<Self>

where Self: Sized + Clone + Send + Sync + 'static, Self::Error: Send + 'static,

Waits for enqueued records to be delivered, or until timeout elapses.

fn shared(self) -> SharedProducer

where Self: Sized + Send + Sync + 'static, Self::Error: Error + Send + Sync + 'static,

Erases this producer’s transport and error type, so one producer can serve several trackers.