Struct InMemoryEventStream 

pub struct InMemoryEventStream { /* private fields */ }

In-memory event stream for testing and development

Implementations

impl InMemoryEventStream

pub fn new(capacity: usize, buffer_size: usize) -> Self

Create a new in-memory event stream

Arguments

• capacity - Channel capacity for concurrent subscribers
• buffer_size - Maximum number of events to buffer for replay

Examples

use llm_memory_graph::observatory::streaming::InMemoryEventStream;

let stream = InMemoryEventStream::new(100, 1000);

pub async fn get_buffered_events(&self) -> Vec<MemoryGraphEvent>

Get all buffered events

pub async fn clear_buffer(&self)

Clear the event buffer

pub fn subscriber_count(&self) -> usize

Get the number of active subscribers

Trait Implementations

impl Clone for InMemoryEventStream

fn clone(&self) -> InMemoryEventStream

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl EventStream for InMemoryEventStream

fn publish<'life0, 'async_trait>( &'life0 self, event: MemoryGraphEvent, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Publish an event to the stream

fn publish_batch<'life0, 'async_trait>( &'life0 self, events: Vec<MemoryGraphEvent>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Publish multiple events in batch

fn subscribe(&self) -> Pin<Box<dyn Stream<Item = MemoryGraphEvent> + Send + '_>>

Subscribe to the event stream