Publish a message event
(&self, def: &'static BusEventDef, msg: &SessionMessage)
| 794 | |
| 795 | /// Publish a message event |
| 796 | fn publish_message_event(&self, def: &'static BusEventDef, msg: &SessionMessage) { |
| 797 | if let Ok(json) = serde_json::to_value(msg) { |
| 798 | self.publish_event(def, serde_json::json!({ "info": json })); |
| 799 | } |
| 800 | } |
| 801 | |
| 802 | /// Publish a part event |
| 803 | fn publish_part_event(&self, def: &'static BusEventDef, part: &MessagePart) { |
no test coverage detected