Skip to main content

EventQueueReader

a2a_protocol_sdk::server

Trait EventQueueReader 

Source 
pub trait EventQueueReader: Send + 'static {
    // Required method
    fn read(
        &mut self,
    ) -> Pin<Box<dyn Future<Output = Option<Result<StreamResponse, A2aError>>> + Send + '_>>;
}
Expand description

Trait for reading streaming events.

NOT object-safe (used as a concrete type internally). The async fn is fine because this trait is never used behind dyn.

Required Methods§

Source

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.

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§