Struct MockSubscriber 

pub struct MockSubscriber<E> {
    _phantom: PhantomData<E>,
}

Helper for creating test event streams.

Wraps a list of events into a stream of MockReceivedEvent values and returns ack-checkers alongside so tests can verify acknowledgment.

use arminius_lib_message_bus::{
	Event, ReceivedEvent, mock::MockSubscriber,
};
use futures::StreamExt;
use serde::{Deserialize, Serialize};

#[derive(Clone, Debug, Serialize, Deserialize)]
struct Ping {
	id: u32,
}
impl Event for Ping {
	const SUBJECT: &str = "Ping.v1";
}

let (mut stream, checkers) =
	MockSubscriber::new().create_stream(vec![Ping { id: 1 }]);
while let Some(Ok(event)) = stream.next().await {
	event.ack().await.unwrap();
}
assert!(checkers[0].was_acked());

Fields

_phantom: PhantomData<E>

Binds the subscriber to its event type E.

Implementations

impl<E: Event + Clone> MockSubscriber<E>

pub fn new() -> Self

Creates a new MockSubscriber.

pub fn create_stream( &self, events: Vec<E>, ) -> (impl Stream<Item = Result<MockReceivedEvent<E>, Error>> + use<E>, Vec<MockReceivedEvent<E>>)

Wraps events into a stream of MockReceivedEvent values.

Returns the stream and a parallel Vec of the same wrapped events so callers can call MockReceivedEvent::was_acked after processing.

Trait Implementations

impl<E: Debug> Debug for MockSubscriber<E>

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

Formats the value using the given formatter.

impl<E: Default> Default for MockSubscriber<E>

fn default() -> MockSubscriber<E>

Returns the “default value” for a type.