Struct MemoryPubsub 

pub struct MemoryPubsub { /* private fields */ }

In-process Pubsub impl.

Implementations

impl MemoryPubsub

pub fn new() -> Self

Build an empty pubsub with the default 1024-message per-channel buffer.

pub fn with_buffer_size(buffer: usize) -> Self

Build an empty pubsub with a custom per-channel buffer size. Larger buffers tolerate slow subscribers; smaller buffers reject fast publishers earlier (slow subscribers see BusError::Retryable("subscriber lagged")).

pub async fn remove_subject(&self, pattern: &str)

Drop the broadcast channel for pattern. Used by crate::request_reply::MemoryRequestReply to clean up the short-lived _reply.{id} subjects it mints per RPC — without this the per-pattern stores grow unbounded with one entry per request.

Safe to call when no entry exists; behaves as a no-op. Removes from whichever store (concrete or wildcard) holds the entry.

pub async fn subject_count(&self) -> usize

Number of active subscription patterns currently retained across both concrete and wildcard stores. Test/observability helper; production callers should not rely on the exact value.

Trait Implementations

impl Clone for MemoryPubsub

fn clone(&self) -> MemoryPubsub

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for MemoryPubsub

fn default() -> Self

Returns the “default value” for a type.

impl Pubsub for MemoryPubsub

fn publish<'life0, 'life1, 'async_trait>( &'life0 self, subject: &'life1 str, payload: Bytes, headers: Headers, ) -> Pin<Box<dyn Future<Output = Result<(), BusError>> + Send + 'async_trait>>

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

Publish payload on subject with headers.

fn subscribe<'life0, 'life1, 'async_trait>( &'life0 self, subject: &'life1 str, _durable: DurableName, ) -> Pin<Box<dyn Future<Output = Result<MsgStream, BusError>> + Send + 'async_trait>>

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

Subscribe with a durable consumer name. Multiple calls with the same durable form a competing-consumer group sharing replays.