Struct SseParser 

pub struct SseParser { /* private fields */ }

An incremental text/event-stream parser: feed it bytes in any chunks, get back the events they completed.

use rust_web_server::test_client::SseParser;

let mut parser = SseParser::new();
assert!(parser.feed(b"event: tick\ndata: 1\n").unwrap().is_empty());
let events = parser.feed(b"id: 7\n\n").unwrap();
assert_eq!("tick", events[0].event);
assert_eq!("1", events[0].data);
assert_eq!(Some("7"), events[0].id.as_deref());

Implementations

impl SseParser

pub fn new() -> Self

A parser at the start of a stream.

pub fn comments(&self) -> usize

Comment lines (: …, keep-alives) seen so far.

pub fn feed(&mut self, bytes: &[u8]) -> Result<Vec<SseFrame>, String>

Parse bytes, returning the events whose blank line they contained. An event or line over MAX_EVENT_BYTES is an error (the parser is then reset to the start of a stream).

Trait Implementations

impl Debug for SseParser

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

Formats the value using the given formatter.

impl Default for SseParser

fn default() -> Self

Returns the “default value” for a type.