diff --git a/lib/rustlers/bus.rs b/lib/rustlers/bus.rs index 7bb22f3..9195a60 100644 --- a/lib/rustlers/bus.rs +++ b/lib/rustlers/bus.rs @@ -1,8 +1,6 @@ use std::{convert::Infallible, fmt::Debug}; -use eyre::Result; -use rxrust::ops::box_it::CloneableBoxOpThreads; -use tonic::async_trait; +use {eyre::Result, rxrust::ops::box_it::CloneableBoxOpThreads, tonic::async_trait}; pub mod redis; diff --git a/lib/rustlers/svc.rs b/lib/rustlers/svc.rs index e025ca6..e092441 100644 --- a/lib/rustlers/svc.rs +++ b/lib/rustlers/svc.rs @@ -95,7 +95,7 @@ where info!("Starting rustlers"); let markets = self.market_svc.get_all_with_tickers().await?; - if markets.len() > 0 { + if !markets.is_empty() { let (sender, mut receiver) = tokio::sync::mpsc::channel(100); for (market, tickers) in markets {