pub async fn read_sse_from_bytes( body: Pin<Box<dyn Stream<Item = Result<Bytes, Error>> + Send + Sync>>, max_bytes: Option<u64>, ) -> Result<Vec<SseEvent>, Error>
Reads a streaming body to completion and parses SSE events.