Struct MemorySubscriber 

pub struct MemorySubscriber<Log = Discarding> { /* private fields */ }

Subscriber returned by MemoryBroker::subscribe. Yields one MemoryMessage per delivery; consumers must call ack or nack on each.

Also consumable in batches through the BatchSubscriber capability, which caps each batch at the size it is asked for and allocates it at that size up front. A subscription of a Retaining broker is repositionable over its publish log through the Seekable capability: mint a MemorySeeker with seeker before opening the stream.

Trait Implementations

impl<Log: LogMode> BatchSubscriber for MemorySubscriber<Log>

Greedy batching: a batch is the first awaited delivery plus everything already buffered, up to the size the registration asked for. Partial batches ship immediately, so no deadline timer is needed - the in-memory transport has nothing to wait for. Each batch is allocated at the requested size up front, so a partial batch holds the room of a full one.

type Batch = Vec<MemoryMessage<Log>>

Container yielded by batches. Implementations choose between Vec, custom iterators, or anything else that yields the underlying Subscriber::Message.

fn batches( &mut self, size: NonZeroUsize, ) -> impl Stream<Item = Result<Self::Batch, <Self as Subscriber>::Error>> + Send + '_

Returns a stream of batches of at most size messages.

impl<Log> Debug for MemorySubscriber<Log>

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

Formats the value using the given formatter.

impl<Log> Drop for MemorySubscriber<Log>

Available on crate feature testing only.

fn drop(&mut self)

What is still queued leaves with the subscription, so the harness stops counting it in flight. A delivery handed back unsettled while the service tears down (a fail-fast panic) lands here, and the reaction the test waits on is over once the subscription is gone.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl Seekable for MemorySubscriber<Retaining>

Seeking is native on a retaining broker: it keeps a bounded publish log per name, so a subscription can re-enqueue any retained suffix of it. A discarding broker keeps no log, and its subscriptions carry no seek surface at all.

type Seeker = MemorySeeker

The handle usable while this subscriber’s stream is running.

fn seeker(&self) -> MemorySeeker

Mints a handle for repositioning this subscription.

impl<Log: LogMode> Subscriber for MemorySubscriber<Log>

type Message = MemoryMessage<Log>

The message type yielded by this subscriber.

type Error = !

The error type yielded by the stream when delivery fails.

fn stream( &mut self, ) -> impl Stream<Item = Result<Self::Message, Self::Error>> + Send + '_

Returns a stream of broker deliveries.