Struct PublishedAssertions 

pub struct PublishedAssertions<T> { /* private fields */ }

Assertions over what was published to one channel, read from the broker’s publish log or from an Out slot’s view. The type parameter T is the expected payload type for with.

Implementations

impl<T> PublishedAssertions<T>

pub fn assert_called_once(self) -> Self

Asserts exactly one message was published to this channel.

Panics

Panics if zero or more than one message was published.

pub fn assert_called(self, times: usize) -> Self

Asserts exactly times messages were published to this channel.

Panics

Panics if the published count differs from times.

pub fn assert_not_called(self)

Asserts nothing was published to this channel.

Panics

Panics if any message was published.

pub fn messages(&self) -> &[RawMessage]

Every message published to this channel, in publish order, for custom inspection beyond the built-in assertions. Bind the assertions to a variable to borrow them: let pubs = tb.broker::<B>().published::<T>("x"); for m in pubs.messages() { .. }.

pub fn decoded_as<U>(self) -> PublishedAssertions<U>

Re-types the expected payload, for assertion sources that do not name one up front (tb.out::<Slot>().decoded_as::<Reply>().with(&expected)).

pub fn with_options<Options>(self, expected: &Options) -> Self

where Options: PartialEq + Debug + 'static,

Asserts the most recent publish carried exactly expected as the broker’s per-message options.

The options are what the broker’s builder steps set on that one publish (see PublishBuilder::options_mut); a publish no step touched carried none, which assert_options_default asserts. The harness records them with every publish the runtime makes (a reply, an Out slot publish, a retry copy), on the broker it went to, so a broker’s view and a slot view both read them.

Panics

Panics if nothing was published, the harness cannot say which options the most recent publish carried (the test published it itself, a publisher the runtime did not pair made it, or another publish there has the same payload and either the order of the two is unknown or the harness never saw that one), it carried none, the broker’s options type is not Options, or the value differs from expected.

pub fn assert_options_default(self) -> Self

Asserts the most recent publish carried no per-message options: no builder step ran on it, and the publish policy’s own settings applied.

Recorded for every publish the runtime makes, like with_options.

Panics

Panics if nothing was published, the harness cannot say which options the most recent publish carried (see with_options), or a step did set options on the publish.

pub fn with_raw(self, bytes: &[u8]) -> Self

Asserts the most recent published payload equals bytes.

Panics

Panics if nothing was published, or the raw payload differs.

pub fn with_header(self, name: &str, value: impl AsRef<[u8]>) -> Self

Asserts the most recent published message carries the header name with value.

What a publish transform or an app-wide publish_layer put on the message is read here: the assertion sees the message as it left, so a stamp added on the way out shows up on the reply channel and on tb.out::<Marker>() alike.

Panics

Panics if nothing was published, the header is absent, or its value differs.

impl<T> PublishedAssertions<T>

where T: DeserializeOwned + PartialEq + Debug,

pub fn with(self, expected: &T) -> Self

Asserts the most recent published payload decodes (with DefaultCodec) to expected. If the publisher uses a different codec, use with_codec.

Panics

Panics if nothing was published, the payload fails to decode, or it differs from expected.

impl<T> PublishedAssertions<T>

where T: DeserializeOwned + PartialEq + Debug,

pub fn with_codec<C: Codec>(self, codec: &C, expected: &T) -> Self

Like with, but decodes the published payload with codec - use it when the publisher was built with a non-default codec.

Panics

Panics if nothing was published, the payload fails to decode, or it differs from expected.

impl<T: DeserializeOwned> PublishedAssertions<T>

pub fn decoded(&self) -> Vec<T>

Decodes every message published to this channel (with DefaultCodec), in publish order, for custom inspection. Use decoded_with for a non-default codec.

Panics

Panics if any published payload fails to decode as T.

impl<T: DeserializeOwned> PublishedAssertions<T>

pub fn decoded_with<C: Codec>(&self, codec: &C) -> Vec<T>

Like decoded, but decodes with codec - use it when the publisher was built with a non-default codec.

Panics

Panics if any published payload fails to decode as T.

Trait Implementations

impl<T: Debug> Debug for PublishedAssertions<T>

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

Formats the value using the given formatter.