doido-cable 0.0.17

Action Cable analogue: channels, broadcasts, Turbo-friendly pub/sub backends for Doido.
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

use doido_cable::{Channel, ChannelContext};

struct EchoChannel;

#[async_trait::async_trait]
impl Channel for EchoChannel {
    async fn subscribed(&self, _ctx: &ChannelContext) -> doido_core::Result<()> {
        Ok(())
    }
    async fn unsubscribed(&self, _ctx: &ChannelContext) -> doido_core::Result<()> {
        Ok(())
    }
    async fn received(
        &self,
        _ctx: &ChannelContext,
        _data: serde_json::Value,
    ) -> doido_core::Result<()> {
        Ok(())
    }
}

#[test]
fn test_channel_trait_is_object_safe() {
    let _ch: &dyn Channel = &EchoChannel;
}

#[tokio::test]
async fn test_channel_subscribed_called() {
    let ch = EchoChannel;
    let (ctx, _rx) = ChannelContext::for_test("test");
    ch.subscribed(&ctx).await.unwrap();
}