Struct SSEProcessor 

pub struct SSEProcessor { /* private fields */ }

Implementations

impl SSEProcessor

pub fn new_with_timeout(timeout_ms: u64) -> Self

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: EventStream, ) -> Pin<Box<dyn Future<Output = Result<EventStream, AnalyzerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Process an event stream and return a processed stream

impl Default for SSEProcessor

fn default() -> Self

Returns the “default value” for a type.