Struct InjectSink 

pub struct InjectSink<'a>(/* private fields */);

The publish builder’s sink for the harness.

It injects the message onto a broker’s in-process transport the way an external producer would, then drives the resulting reaction to a standstill before the publish returns.

Produced by the message(..) entry point of TestApp and BrokerHandle, so a test injects through the same positions - destination, typed headers, codec - that the service itself publishes through. You never name this type.

Trait Implementations

impl Debug for InjectSink<'_>

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

Formats the value using the given formatter.

impl PublishSink for InjectSink<'_>

type Payload = Lend

How the publisher or transaction underneath consumes the payload, forwarded so the builder encodes into the form it declared. See Publisher::Payload.

type Error = TestError

The error the sink reports when the message cannot be sent.

type Options = ()

The per-message settings of the publisher or transaction underneath, forwarded so the publish builder can carry them.

async fn send( &mut self, msg: OutgoingMessage<'_, &[u8]>, _options: Option<&Self::Options>, ) -> Result<(), Self::Error>

Sends one message into the sink, with the settings the builder’s steps put on it.

fn base_headers(&self) -> Option<&HeaderMap>

The headers the sink contributes underneath the publish’s own, or None when it contributes nothing.