Struct EventReceiver 

pub struct EventReceiver { /* private fields */ }

Blocking event-only subscriber for application worker threads. The handshake is bounded and acknowledged; no subprocess or second daemon is required. EOF/error is a discontinuity: callers must clear held state before reconnect.

Implementations

impl EventReceiver

pub fn connect(addr: &str, token: &str) -> Result<EventReceiver, AppError>

pub fn next_event(&mut self) -> Result<Option<SemanticEvent>, AppError>

pub fn cancellation_handle(&self) -> Result<TcpStream, AppError>

Clone only for cancellation from an owning thread; shutting this handle down wakes a worker blocked in next_event().

pub fn close(&self)