Struct InMemoryQueueReader 

pub struct InMemoryQueueReader { /* private fields */ }

In-memory EventQueueReader backed by a broadcast channel receiver.

If the reader falls behind (slower than the writer), missed events are silently skipped and the reader continues with the next available event.

Optionally holds a “pending first event” that is yielded before any broadcast events. This is used by SubscribeToTask to emit a Task snapshot as the first event without broadcasting it to all subscribers.

Implementations

impl InMemoryQueueReader

pub fn set_first_event(&mut self, event: StreamResponse)

Sets a pending first event to be yielded before broadcast events.

Trait Implementations

impl Debug for InMemoryQueueReader

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

Formats the value using the given formatter.

impl EventQueueReader for InMemoryQueueReader

fn read( &mut self, ) -> Pin<Box<dyn Future<Output = Option<Result<StreamResponse, A2aError>>> + Send + '_>>

Reads the next event, returning None when the stream is closed.