Struct InMemoryFlowEventObserver 

pub struct InMemoryFlowEventObserver { /* private fields */ }

In-memory observer for tests, local debugging, and embedded hosts.

Implementations

impl InMemoryFlowEventObserver

pub fn new() -> Self

Creates an empty in-memory observer.

pub async fn events(&self) -> Vec<FlowEventEnvelope>

Returns a snapshot of all observed envelopes in commit order.

pub async fn event_keys(&self) -> Vec<&'static str>

Returns routing keys for all observed events in commit order.

Trait Implementations

impl Debug for InMemoryFlowEventObserver

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

Formats the value using the given formatter.

impl Default for InMemoryFlowEventObserver

fn default() -> InMemoryFlowEventObserver

Returns the “default value” for a type.

impl FlowEventObserver for InMemoryFlowEventObserver

fn observe<'life0, 'async_trait>( &'life0 self, envelope: FlowEventEnvelope, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handles one event after it has committed to the durable store.