Struct MemoryAdapter 

pub struct MemoryAdapter { /* private fields */ }

Memory-based message broker

Implementations

impl MemoryAdapter

pub fn new(buffer_size: usize) -> Self

pub async fn publish( &self, topic: impl Into<String>, payload: Value, ) -> Result<()>

Publish a message to a topic

pub async fn subscribe<H>( &self, topic: impl Into<String>, handler: Arc<H>, ) -> Result<()>

where H: MessageHandler + 'static,

Subscribe to a topic with a handler

pub async fn subscribe_fn<F, Fut>( &self, topic: impl Into<String>, handler: F, ) -> Result<()>

where F: Fn(Message) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

Subscribe with a closure

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

Get list of all topics

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

Get subscriber count for a topic

Trait Implementations

impl Default for MemoryAdapter

fn default() -> Self

Returns the “default value” for a type.