Struct AsyncEventEmitter 

pub struct AsyncEventEmitter<P: EventPublisher + 'static> { /* private fields */ }

Async event emitter for non-blocking event emission

This struct wraps an EventPublisher and provides fire-and-forget emission semantics. Events are sent in background tasks using tokio::spawn, ensuring they never block the caller.

Implementations

impl<P: EventPublisher + 'static> AsyncEventEmitter<P>

pub fn new(publisher: Arc<P>) -> Self

Create a new async event emitter

Arguments

• publisher - The event publisher to use for sending events

Examples

use llm_memory_graph::observatory::{AsyncEventEmitter, InMemoryPublisher};
use std::sync::Arc;

let publisher = Arc::new(InMemoryPublisher::new());
let emitter = AsyncEventEmitter::new(publisher);

pub fn new_silent(publisher: Arc<P>) -> Self

Create a new async event emitter without error logging

pub fn emit(&self, event: MemoryGraphEvent)

Emit an event without blocking

This method spawns a background task to publish the event and returns immediately. Errors during emission are logged but don’t affect the caller.

Arguments

• event - The event to emit

Examples

let publisher = Arc::new(InMemoryPublisher::new());
let emitter = AsyncEventEmitter::new(publisher);

let event = MemoryGraphEvent::QueryExecuted {
    query_type: "test".to_string(),
    results_count: 10,
    duration_ms: 50,
    timestamp: chrono::Utc::now(),
};

emitter.emit(event); // Returns immediately

pub fn emit_batch(&self, events: Vec<MemoryGraphEvent>)

Emit multiple events without blocking

Arguments

• events - Vector of events to emit

pub async fn emit_sync(&self, event: MemoryGraphEvent) -> Result<()>

Emit an event and wait for completion

Unlike emit(), this method waits for the event to be published and returns any errors. Useful for testing and critical events.

Arguments

• event - The event to emit

Returns

Returns Ok(()) if the event was successfully published

pub async fn stats(&self) -> EmissionStatsSnapshot

Get emission statistics

Returns

Returns a snapshot of current emission statistics

pub async fn reset_stats(&self)

Reset all statistics to zero

pub fn publisher(&self) -> &Arc<P>

Get the underlying publisher

Trait Implementations

impl<P: Clone + EventPublisher + 'static> Clone for AsyncEventEmitter<P>

fn clone(&self) -> AsyncEventEmitter<P>

Returns a duplicate of the value.

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

Performs copy-assignment from source.