Struct SSEProcessor 

pub struct SSEProcessor { /* private fields */ }

Implementations

impl SSEProcessor

pub fn new_with_timeout(timeout_ms: u64) -> SSEProcessor

pub fn is_sse_data(data: &str) -> bool

pub fn parse_sse_events_from_chunk(chunk_content: &str) -> Vec<SSEEvent>

pub fn parse_sse_events(data: &str) -> Vec<SSEEvent>

pub fn clean_chunked_content(content: &str) -> String

Trait Implementations

impl Analyzer for SSEProcessor

fn process<'life0, 'async_trait>( &'life0 mut self, stream: Pin<Box<dyn Stream<Item = Event> + Send>>, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Event> + Send>>, Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, SSEProcessor: 'async_trait,

impl Default for SSEProcessor

fn default() -> SSEProcessor

Returns the “default value” for a type.