acter/api/room/
subscription.rs

1
2
3
4
5
6
7
8
9
10
use acter_core::referencing::ExecuteReference;
use tokio::sync::broadcast::Receiver;

use super::Room;

impl Room {
    pub fn subscribe<K: Into<ExecuteReference>>(&self, key: K) -> Receiver<()> {
        self.core.subscribe(key)
    }
}