pub async fn assert_published<T: Clone + Send + Sync + 'static>(
broker: &InMemoryBroker<T>,
topic: &str,
predicate: impl Fn(&Message<T>) -> bool,
)Expand description
Assert that at least one message on topic satisfies the predicate.
ยงPanics
Panics when no matching message is found.