Struct RedisTestSubscriber 

pub struct RedisTestSubscriber { /* private fields */ }

Subscriber returned by crate::testing::RedisTestBroker::subscribe.

Trait Implementations

impl BatchSubscriber for RedisTestSubscriber

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

Drains whatever is already buffered in the subscriber’s channel (at least one, at most [TEST_BATCH_LIMIT] messages). Blocks until the first message arrives.

type Batch = Vec<RedisTestMessage>

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

impl Debug for RedisTestSubscriber

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

Formats the value using the given formatter.

impl Drop for RedisTestSubscriber

fn drop(&mut self)

Executes the destructor for this type.

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 Subscriber for RedisTestSubscriber

type Message = RedisTestMessage

The message type yielded by this subscriber.

type Error = RedisError

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.