Type Alias MockEventBus 

pub type MockEventBus = ChannelEventBus;

Backwards-compatible alias.

Aliased Type

pub struct MockEventBus {
    sender: UnboundedSender<EngineMessage>,
    receiver: Arc<RwLock<Option<UnboundedReceiver<EngineMessage>>>>,
    subscribers: Arc<RwLock<HashMap<String, Vec<UnboundedSender<EngineMessage>>>>>,
    subscribers_with_offsets: Arc<RwLock<HashMap<String, Vec<UnboundedSender<LegacyMessageEnvelope>>>>>,
    subscribers_with_sequence: Arc<RwLock<HashMap<String, Vec<UnboundedSender<MessageEnvelope>>>>>,
    sequence: Arc<AtomicU64>,
    replay_error: Arc<RwLock<Option<String>>>,
}

Fields

sender: UnboundedSender<EngineMessage>

receiver: Arc<RwLock<Option<UnboundedReceiver<EngineMessage>>>>

subscribers: Arc<RwLock<HashMap<String, Vec<UnboundedSender<EngineMessage>>>>>

subscribers_with_offsets: Arc<RwLock<HashMap<String, Vec<UnboundedSender<LegacyMessageEnvelope>>>>>

subscribers_with_sequence: Arc<RwLock<HashMap<String, Vec<UnboundedSender<MessageEnvelope>>>>>

sequence: Arc<AtomicU64>

Monotonic sequence counter, incremented on each event dispatch.

replay_error: Arc<RwLock<Option<String>>>

When set, replay_from_offsets returns this error instead of Ok. Used to test graceful handling of replay failures.