Struct EventChannel 

pub struct EventChannel { /* private fields */ }

A running bidirectional HTTP event channel.

Created via EventChannel::start and stored in AgentSession. The channel is torn down when EventChannel is dropped (the server graceful-shutdown completes).

Implementations

impl EventChannel

pub fn start(config: EventChannelConfig) -> Result<Option<Self>, AgentError>

Bind the HTTP server on EventChannelConfig::listen and spawn the event-loop in a background tokio task. Returns Ok(None) when config.enabled is false, or an error if binding fails.

This is a synchronous method — it uses a std TcpListener to bind, then converts the socket to a tokio listener.

pub fn publish(&self, event: &TurnEvent)

Publish a TurnEvent to all connected SSE clients.

pub fn try_drain_incoming(&mut self) -> Vec<ExternalEvent>

Non-blocking drain of all external events whose topic matches a configured subscription pattern.

pub fn to_system_message(event: &ExternalEvent) -> Message

Convert a drained ExternalEvent into a system message ready for injection into the conversation.