Struct MockReceivedEvent 

pub struct MockReceivedEvent<E> {
    event: E,
    acked: Arc<Mutex<bool>>,
    context: Context,
}

A received event wrapper for use in unit tests.

Tracks whether ack was called, so tests can assert that processing code acknowledges messages correctly.

Fields

event: E

The wrapped event.

acked: Arc<Mutex<bool>>

Whether ack has been called.

context: Context

The OTel context associated with this event.

Implementations

impl<E> MockReceivedEvent<E>

pub fn new(event: E) -> Self

Creates a new wrapper MockReceivedEvent around an event with new OTel context and that is not yet acknowledged.

impl<E> MockReceivedEvent<E>

pub fn was_acked(&self) -> bool

Returns true if ack has been called on this event.

Trait Implementations

impl<E: Clone> Clone for MockReceivedEvent<E>

fn clone(&self) -> MockReceivedEvent<E>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E: Debug> Debug for MockReceivedEvent<E>

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

Formats the value using the given formatter.

impl<E: Event> Deref for MockReceivedEvent<E>

type Target = E

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<E: Event + Clone> From<&E> for MockReceivedEvent<E>

fn from(value: &E) -> Self

Converts to this type from the input type.

impl<E: Event> From<E> for MockReceivedEvent<E>

fn from(value: E) -> Self

Converts to this type from the input type.

impl<E: PartialEq> PartialEq for MockReceivedEvent<E>

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<E: Event> ReceivedEvent<E> for MockReceivedEvent<E>

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

Acknowledge processing of this event.

fn context(&self) -> &Context

Returns the OpenTelemetry context propagated with this event.

fn event(&self) -> &E

Returns a reference to the received event data.