MOD: Rework live example

databento · Aug 26, 2024 · 7642711 · 7642711
1 parent 3bcc2e5
commit 7642711
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/README.md b/README.md
@@ -54,8 +54,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
 
     let mut symbol_map = PitSymbolMap::new();
     // Get the next trade
-    loop {
-        let rec = client.next_record().await?.unwrap();
+    while let Some(rec) = client.next_record().await? {
         if let Some(trade) = rec.get::<TradeMsg>() {
             let symbol = &symbol_map[trade];
             println!("Received trade for {symbol}: {trade:?}");

diff --git a/examples/live.rs b/examples/live.rs
@@ -28,8 +28,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
 
     let mut symbol_map = PitSymbolMap::new();
     // Get the next trade
-    loop {
-        let rec = client.next_record().await?.unwrap();
+    while let Some(rec) = client.next_record().await? {
         if let Some(trade) = rec.get::<TradeMsg>() {
             let symbol = &symbol_map[trade];
             println!("Received trade for {symbol}: {trade:?}");