spinta 0.1.1

Server-sent events client that works natively and on the web (WASM)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use crate::{EsEvent, EventHandler, Result};
use eventsource_client::{Client, SSE};
use futures::StreamExt;

pub fn es_connect(url: String, on_event: EventHandler) -> Result<()> {
    tokio::spawn(async move {
        es_connect_async(url.clone(), on_event).await;
    });

    Ok(())
}

async fn es_connect_async(url: String, on_event: EventHandler) {
    let client = match eventsource_client::ClientBuilder::for_url(&url) {
        Ok(res) => res.build(),
        Err(err) => {
            on_event(EsEvent::Error(err.source().unwrap().to_string()));
            return;
        }
    };

    let stream = client.stream();

    let reader = stream.for_each(move |event| {
        match event {
            Ok(message) => match message {
                SSE::Event(ev) => {
                    on_event(EsEvent::Message(ev.data));
                    println!("got an event: {}", ev.event_type);
                }
                SSE::Comment(comment) => {
                    println!("got a comment: \n{}", comment);
                }
            },
            Err(err) => {
                on_event(EsEvent::Error(format!("error streaming events: {:?}", err)));
            }
        }
        async {}
    });

    futures_util::pin_mut!(reader);
    reader.await;
}