Struct InMemoryEventEmitter 

pub struct InMemoryEventEmitter { /* private fields */ }

In-memory event emitter for testing

Stores emitted events in memory for inspection. Useful for testing and examples where you want to verify events without a database.

Example

use everruns_core::memory::InMemoryEventEmitter;

let emitter = InMemoryEventEmitter::new();

// Emit events...

// Check emitted events
let events = emitter.events().await;
assert_eq!(events.len(), 2);

Implementations

impl InMemoryEventEmitter

pub fn new() -> Self

Create a new in-memory event emitter

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

Get all emitted events

pub async fn event_count(&self) -> usize

Get the count of emitted events

pub async fn clear(&self)

Clear all events

pub async fn events_by_type(&self, event_type: &str) -> Vec<Event>

Get events by type

pub async fn events_for_session(&self, session_id: Uuid) -> Vec<Event>

Get events for a specific session

Trait Implementations

impl Clone for InMemoryEventEmitter

fn clone(&self) -> InMemoryEventEmitter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryEventEmitter

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

Formats the value using the given formatter.

impl Default for InMemoryEventEmitter

fn default() -> InMemoryEventEmitter

Returns the “default value” for a type.

impl EventEmitter for InMemoryEventEmitter

fn emit<'life0, 'async_trait>( &'life0 self, request: EventRequest, ) -> Pin<Box<dyn Future<Output = Result<Event>> + Send + 'async_trait>>

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

Emit an event request