pub fn parse_sse_stream<S, E>(byte_stream: S) -> SseStreamwhere S: Stream<Item = Result<Bytes, E>> + Send + 'static, E: Error + Send + 'static,