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
use crate::websocket::ServerSocket; use dbui_core::ResponseMessage; use actix::Addr; #[derive(Debug)] pub struct SendResponseMessage { msg: ResponseMessage } impl SendResponseMessage { pub(crate) fn msg(&self) -> &ResponseMessage { &self.msg } } impl actix::Message for SendResponseMessage { type Result = (); } #[derive(derive_more::Constructor)] pub(crate) struct ServerSender { addr: Addr<ServerSocket> } impl dbui_service::cache::SendCallback for ServerSender { fn send_message(&self, msg: ResponseMessage) { self.addr.do_send(SendResponseMessage { msg }); } }