sse-codec

A futures_codec that encodes and decodes Server-Sent Event/Event Sourcing streams.

文档

在 docs.rs 上。

安装

使用 cargo-edit 做以下操作

cargo add sse-codec

或在 Cargo.toml 中

[dependencies]
sse-codec = "0.3.2"

相关

• surf-sse - 基于 Surf 和 sse-codec 的 EventSource 客户端。

许可

MPL-2.0

lib.rs:

A futures_codec that encodes and decodes Server-Sent Event/Event Sourcing streams.

它输出或序列化完整消息，以及元消息 retry:。

示例

use sse_codec::{decode_stream, Event};
use futures::stream::TryStreamExt; // for try_next()

let response = surf::get("https://some-site.com/events").await?;
let mut events = decode_stream(response);

while let Some(event) = events.try_next().await? {
    println!("incoming: {:?}", event);

    match event {
        Event::Retry { retry } => {
            // change a retry timer value or something
        }
        Event::Message { event, .. } if event == "stop" => {
            break;
        }
        Event::Message { id, event, data } => {
            if let Some(id) = id {
                // change the last event ID
            }
            // handle event here
        }
    }
}

来自 web-platform-tests 套件的 EventSource 测试。请参阅 https://github.com/web-platform-tests/wpt/tree/master/eventsource