Struct InMemoryBroker 

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

An in-memory message broker backed by a tokio::sync::broadcast channel.

Create one broker and hand out producers / consumers via InMemoryBroker::producer and InMemoryBroker::consumer.

Every message sent through the broker is recorded in an internal history so that test assertion helpers can inspect what was published.

Implementations

impl<T: Clone + Send + Sync + 'static> InMemoryBroker<T>

pub fn new(capacity: usize) -> Self

Create a broker with the given channel capacity.

pub fn producer(&self) -> InMemoryProducer<T>

Create a producer attached to this broker.

pub fn with_history_limit(capacity: usize, history_limit: usize) -> Self

Create a broker with explicit channel capacity and bounded history limit.

The default InMemoryBroker::new bounds history by channel capacity. Use this constructor when tests need a different history limit.

pub fn consumer(&self) -> InMemoryConsumer<T>

Create a consumer attached to this broker.

pub async fn messages(&self, topic: &str) -> Vec<Message<T>>

Return a clone of all messages published to topic.

pub async fn all_messages(&self) -> Vec<Message<T>>

Return a clone of every message published to any topic.

pub async fn message_count(&self, topic: &str) -> usize

Return the number of messages published to topic.

pub async fn reset(&self)

Clear the recorded message history.

pub async fn create_topic(&self, topic: &str)

Pre-create a topic so that it appears in InMemoryBroker::topic_names.

pub async fn topic_names(&self) -> Vec<String>

Return the sorted set of topic names that have been created or published to.

Trait Implementations

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

fn clone(&self) -> InMemoryBroker<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 InMemoryBroker<T>

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

Formats the value using the given formatter.

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

fn default() -> Self

Returns the “default value” for a type.