rok_broadcasting/event.rs
1use serde::Serialize;
2use serde_json::Value;
3
4/// A broadcast event ready for delivery.
5#[derive(Debug, Clone, Serialize)]
6pub struct BroadcastEvent {
7 pub channel: String,
8 pub event: String,
9 pub data: Value,
10}
11
12impl BroadcastEvent {
13 pub fn new(channel: impl Into<String>, event: impl Into<String>, data: Value) -> Self {
14 Self {
15 channel: channel.into(),
16 event: event.into(),
17 data,
18 }
19 }
20}