Struct MockReceivedCommand 

pub struct MockReceivedCommand<C: Command> {
    cmd: C,
    context: Context,
    reply_tx: Arc<Mutex<Option<Sender<Vec<u8>>>>>,
}

Mock implementation of ReceivedCommand for unit tests.

Captures the reply sent by ReceivedCommand::reply in a channel so tests can assert on what the handler replied without a running NATS server. Obtain a (MockReceivedCommand<C>, ReplyChecker<C::Reply>) pair from MockReceivedCommand::new.

Fields

cmd: C

The wrapped command.

context: Context

The OTel context associated with this command.

reply_tx: Arc<Mutex<Option<Sender<Vec<u8>>>>>

Channel the handler’s reply is sent on; taken on first reply.

Implementations

impl<C: Command> MockReceivedCommand<C>

pub fn new(cmd: C) -> (Self, ReplyChecker<C::Reply>)

Creates a MockReceivedCommand paired with a ReplyChecker that receives the reply sent by reply.

pub(crate) fn with_reply_channel(cmd: C, reply_tx: Sender<Vec<u8>>) -> Self

Constructs a received command whose reply is delivered through reply_tx.

Used by the in-memory bus to route a handler’s reply back to the originating Requester::request call, instead of capturing it in a ReplyChecker.

Trait Implementations

impl<C: Command + Debug> Debug for MockReceivedCommand<C>

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

Formats the value using the given formatter.

impl<C: Command> Deref for MockReceivedCommand<C>

type Target = C

The resulting type after dereferencing.

fn deref(&self) -> &C

Dereferences the value.

impl<C: Command> ReceivedCommand<C> for MockReceivedCommand<C>

async fn ack(&self) -> Result<(), Error>

Does nothing: there is no broker here to acknowledge to. Tests that need to observe acknowledgement order need a double of their own.

async fn reply(&self, response: C::Reply) -> Result<(), Error>

Send response back to the requester and acknowledge the command.

fn context(&self) -> &Context

Returns the OpenTelemetry context propagated with this command.

fn command(&self) -> &C

Returns a reference to the received command data.