Struct InMemoryQueueWriter 

pub struct InMemoryQueueWriter { /* private fields */ }

In-memory EventQueueWriter backed by an mpsc channel sender.

Enforces a maximum serialized event size to prevent OOM from oversized events written by executors, and a write timeout to prevent blocking indefinitely on slow clients (PR-1).

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

Formats the value using the given formatter.

impl EventQueueWriter for InMemoryQueueWriter

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

Writes a streaming event to the queue.

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

Signals that no more events will be written.