fn sse(ct: u8) -> impl Stream<Item = Result<Event, Infallible>> {
    futures::stream::iter((0..=ct).into_iter().map({
        |i| {
            let mut gen =
                Generator::new(r"[^\r\n]*", rand::thread_rng(), DEFAULT_MAX_REPEAT).unwrap();
            let mut data = Vec::new();
            gen.generate(&mut data).unwrap();
            Ok(Event::default()
                .id(i.to_string())
                .data(String::from_utf8_lossy(&data)))
        }
    }))
}
