1 2 3 4 5 6 7 8 9 10 11 12
use super::MurSseEvent; use tokio::sync::mpsc; pub struct MurSseReceiver { pub rx: mpsc::Receiver<MurSseEvent>, } impl MurSseReceiver { pub async fn recv(&mut self) -> Option<MurSseEvent> { self.rx.recv().await } }