phyllo

使用 Actor 模型在 Rust 中实现的 Phoenix 通道。此 crate 通过提供 Socket 和 Channel 抽象来连接、接收和发送消息。整体结构基于 参考 JavaScript 客户端。

示例

警告：返回的结果可能包含 NSFW 链接或评论。

use serde_json::Value;

#[tokio::main]
async fn main() -> anyhow::Result<()> {
    // The socket is generic over a Topic.
    let mut socket = SocketBuilder::new(Url::parse("wss://furbooru.org/socket/websocket")?)
        .build::<String>()
        .await;

    // Each channel is generic over an Event and Payload type.
    // For simplicity we use serde_json::Value, but in your own code you should deserialize
    // to something strongly-typed.
    let (_channel, mut subscription) = socket
        .channel::<String, Value, Value>(ChannelBuilder::new("firehose".to_string()))
        .await?;

    loop {
        let v = subscription.recv().await?;
        println!("{:?}", v);
    }
}

特性

默认情况下未启用 TLS。要支持 TLS，请启用以下任一项

• rustls-native-roots (使用 rustls-native-certs 进行根证书)
• rustls-webpki-roots (使用 webpki-roots 进行根证书)

许可证：MIT OR Apache-2.0