diff --git a/bin/update_logger/src/main.rs b/bin/update_logger/src/main.rs index 746ee13b6..c5b7f35a1 100644 --- a/bin/update_logger/src/main.rs +++ b/bin/update_logger/src/main.rs @@ -11,16 +11,16 @@ async fn app() -> anyhow::Result<()> { let monitor = MonitorClient::new_from_env().await?; - // let (mut rx, _) = monitor.subscribe_to_updates(1000, 5); + let (mut rx, _) = monitor.subscribe_to_updates(1000, 5)?; - // loop { - // let msg = rx.recv().await; - // if let Err(e) = msg { - // error!("🚨 recv error | {e:#?}"); - // break; - // } - // info!("{msg:#?}") - // } + loop { + let msg = rx.recv().await; + if let Err(e) = msg { + error!("🚨 recv error | {e:#?}"); + break; + } + info!("{msg:#?}") + } Ok(()) }