EventSource-Threaded

EventSource-Threaded 是一个用于从 Server-Sent Events 端点读取的 Rust 库。它透明地在一个单独的线程上发送 HTTP 请求，并通过通道接收器仅向用户暴露事件流。它处理自动重新连接以及解析 text/event-stream 数据格式。

EventSource-Threaded 是由 此 EventSource 库 的创建者 lluchs 创建的分支。主要区别包括

• EventSource 客户端现在是线程化的
• 现在支持添加任意头部值（对于需要设置用于授权的cookie等用例非常重要）
• 方法/接口的微小重命名/删除

示例

use eventsource-threaded::reqwest::Client;
use reqwest::Url;

fn main() {
    let receiver = EventSource::new(Url::parse("http://example.com").unwrap());
    loop {
        println!("Received Event: {:?}", receiver.recv());
    }

}

lib.rs:

EventSource-Threaded

EventSource-Threaded 是一个用于从 Server-Sent Events 端点读取的 Rust 库。它透明地在一个单独的线程上发送 HTTP 请求，并通过通道接收器仅向用户暴露事件流。它处理自动重新连接以及解析 text/event-stream 数据格式。

示例

use eventsource-threaded::reqwest::Client;
use reqwest::Url;

fn main() {
    let receiver = EventSource::new(Url::parse("http://example.com").unwrap());
    loop {
        println!("Received Event: {:?}", receiver.recv());
    }
}