use tokio::sync::mpsc;
#[derive(Debug, Clone)]
pub enum RuntimeMessage {
Patch(super::patch_engine::RuntimePatch),
State(super::dev_runtime::RuntimeStateSnapshot),
Event(super::dev_runtime::RuntimeEvent),
}
pub struct RuntimeConnection {
sender: mpsc::Sender<RuntimeMessage>,
}
impl RuntimeConnection {
pub fn new() -> (Self, mpsc::Receiver<RuntimeMessage>) {
let (sender, receiver) = mpsc::channel(100);
(Self { sender }, receiver)
}
pub async fn send(&self, msg: RuntimeMessage) {
let _ = self.sender.send(msg).await;
}
}