socketioxide-emitter 0.1.0

Broadcast events across a Socketioxide cluster from any Rust process
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 fred::{
    clients::SubscriberClient,
    prelude::{ClientLike, PubsubInterface},
};
use socketioxide_emitter::{Driver, IoEmitter};

struct FredConnection(SubscriberClient);
impl Driver for FredConnection {
    type Error = fred::error::Error;

    async fn emit(&self, channel: String, data: Vec<u8>) -> Result<(), Self::Error> {
        self.0.publish::<u16, _, _>(channel, data).await?;
        Ok(())
    }
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = fred::prelude::Config::from_url("redis://127.0.0.1:6379")?;
    let client = fred::prelude::Builder::from_config(config).build_subscriber_client()?;
    client.init().await?;
    let conn = FredConnection(client);

    IoEmitter::new().emit("event", "hello", &conn).await?;
    IoEmitter::new()
        .of("/admin")
        .emit("event", "hello", &conn)
        .await?;
    IoEmitter::new()
        .within("room")
        .emit("event", "hello", &conn)
        .await?;
    IoEmitter::new().to("test1").disconnect(&conn).await?;
    IoEmitter::new()
        .to("test1")
        .except("room1")
        .join(["blabla", "azidnazdoi"], &conn)
        .await?;
    Ok(())
}