Struct InMemoryQueueWriter 

pub struct InMemoryQueueWriter { /* private fields */ }

In-memory EventQueueWriter backed by a broadcast channel sender.

Supports multiple concurrent readers (fan-out) via subscribe(). Enforces a maximum serialized event size to prevent OOM from oversized events written by executors.

Broadcast sends are non-blocking: if a reader falls behind, it will receive a lagged notification and skip missed events rather than blocking the writer.

Implementations

impl InMemoryQueueWriter

pub fn subscribe(&self) -> InMemoryQueueReader

Creates a new reader that will receive all future events from this writer.

This enables fan-out: multiple SSE streams can subscribe to the same event queue, which is required for SubscribeToTask (resubscribe).

Trait Implementations

impl Clone for InMemoryQueueWriter

fn clone(&self) -> InMemoryQueueWriter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InMemoryQueueWriter

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl EventQueueWriter for InMemoryQueueWriter

fn write<'a>( &'a self, event: StreamResponse, ) -> Pin<Box<dyn Future<Output = Result<(), A2aError>> + Send + 'a>>

Writes a streaming event to the queue.

fn close<'a>( &'a self, ) -> Pin<Box<dyn Future<Output = Result<(), A2aError>> + Send + 'a>>

Signals that no more events will be written.