reventsource 0.0.2

Rust eventsource implementation.
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

use crate::event::{Event, EventState};

pub fn parse_line(line: &str, event: &mut Event) -> EventState {
    // data ends with `\n\n`
    if line == "" {
        return EventState::Ready;
    }

    let kv: Vec<&str> = line.splitn(2, ':').collect();
    if kv.len() < 2 {
        return EventState::Pending;
    }
    let k = kv[0];
    let mut v = kv[1];

    // clean up one optional space
    if v.starts_with(' ') {
        v = &v[1..]
    };

    match k {
        "data" => {
            event.data.push_str(v);
            event.data.push('\n');
        }
        "event" => {
            event.event = Some(v.to_string());
        }

        "id" => {
            event.id = Some(v.to_string());
        }
        "retry" => {
            event.retry = Some(v.to_string());
        }
        _ => {}
    }

    EventState::Pending
}