Struct InMemoryProducer 

pub struct InMemoryProducer<T: Clone + Send + Sync + 'static> { /* private fields */ }

An in-memory message producer.

Trait Implementations

impl<T: Clone + Clone + Send + Sync + 'static> Clone for InMemoryProducer<T>

fn clone(&self) -> InMemoryProducer<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Clone + Send + Sync + 'static> Debug for InMemoryProducer<T>

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

Formats the value using the given formatter.

impl EventProducer for InMemoryProducer<Value>

fn publish<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 str, event: Event, ) -> Pin<Box<dyn Future<Output = AppResult<()>> + Send + 'async_trait>>

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

Publish a single event to the given topic.

fn publish_batch<'life0, 'life1, 'async_trait>( &'life0 self, topic: &'life1 str, events: Vec<Event>, ) -> Pin<Box<dyn Future<Output = AppResult<()>> + Send + 'async_trait>>

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

Publish a batch of events to the given topic.

impl<T: Clone + Send + Sync + 'static> MessageProducer<T> for InMemoryProducer<T>

fn send<'life0, 'async_trait>( &'life0 self, msg: Message<T>, ) -> Pin<Box<dyn Future<Output = AppResult<()>> + Send + 'async_trait>>

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

Send a single message.

fn send_batch<'life0, 'async_trait>( &'life0 self, msgs: Vec<Message<T>>, ) -> Pin<Box<dyn Future<Output = AppResult<()>> + Send + 'async_trait>>

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

Send a batch of messages.

fn flush<'life0, 'async_trait>( &'life0 self, _timeout: Duration, ) -> Pin<Box<dyn Future<Output = AppResult<()>> + Send + 'async_trait>>

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

Flush pending messages within the given timeout.

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = AppResult<()>> + Send + 'async_trait>>

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

Close or shut down the producer. Implementations with no persistent resources may no-op.