From 8f73b08fbfd8371122ddd785a4e3056faa3dcb0d Mon Sep 17 00:00:00 2001 From: mbecker20 Date: Fri, 12 Jan 2024 23:50:38 -0800 Subject: [PATCH] update logger --- bin/update_logger/src/main.rs | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) 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(()) }