Struct StreamingMemoryExtractor 

pub struct StreamingMemoryExtractor { /* private fields */ }

Streaming Memory Extractor - core processing engine

Implementations

impl StreamingMemoryExtractor

pub fn new(neural_ner: Arc<NeuralNer>) -> Self

pub async fn create_session( &self, handshake: StreamHandshake, ) -> Result<String, String>

Create a new streaming session

pub async fn cleanup_stale_sessions(&self) -> usize

Remove stale sessions that have been inactive for too long

pub async fn session_count(&self) -> usize

Get current session count

pub async fn process_message( &self, session_id: &str, message: StreamMessage, memory_system: Arc<RwLock<MemorySystem>>, ) -> ExtractionResult

Process incoming message

pub async fn close_session(&self, session_id: &str) -> Option<usize>

Close session and cleanup

pub async fn inject_context( &self, session_id: &str, content: &str, memory_system: Arc<RwLock<MemorySystem>>, graph_memory: Arc<RwLock<GraphMemory>>, ) -> Option<ExtractionResult>

Get session stats Surface relevant memories for streaming content (context injection)

This is the core of bidirectional streaming: as content flows in, relevant memories are surfaced back to the client.

pub async fn get_session_stats(&self, session_id: &str) -> Option<SessionStats>