From e147f90168c10ae32eac407a739c9bf9978a2a9c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Hans=20M=C3=BCndelein?= <hans@muendelein.me>
Date: Wed, 14 Jun 2023 11:19:11 +0200
Subject: [PATCH] Don't error on failing broadcast channel send

---
 crabidy-server/src/playback.rs | 28 ++++++++++++++--------------
 1 file changed, 14 insertions(+), 14 deletions(-)

diff --git a/crabidy-server/src/playback.rs b/crabidy-server/src/playback.rs
index cbc7fe3..3d1bdb8 100644
--- a/crabidy-server/src/playback.rs
+++ b/crabidy-server/src/playback.rs
@@ -120,7 +120,7 @@ impl Playback {
                             let queue_update_tx = self.update_tx.clone();
                             let update = StreamUpdate::Queue(queue.clone().into());
                             if let Err(err) = queue_update_tx.send(update) {
-                                error!("{:?}", err)
+                                debug!("{:?}", err)
                             };
                             queue.current_track()
                         };
@@ -153,7 +153,7 @@ impl Playback {
                             let queue_update_tx = self.update_tx.clone();
                             let update = StreamUpdate::Queue(queue.clone().into());
                             if let Err(err) = queue_update_tx.send(update) {
-                                error!("{:?}", err)
+                                debug!("{:?}", err)
                             }
                         }
                         debug!("que lock released");
@@ -184,7 +184,7 @@ impl Playback {
                             let queue_update_tx = self.update_tx.clone();
                             let update = StreamUpdate::Queue(queue.clone().into());
                             if let Err(err) = queue_update_tx.send(update) {
-                                error!("{:?}", err)
+                                debug!("{:?}", err)
                             }
                         }
                         debug!("queue lock released");
@@ -205,7 +205,7 @@ impl Playback {
                             let queue_update_tx = self.update_tx.clone();
                             let update = StreamUpdate::Queue(queue.clone().into());
                             if let Err(err) = queue_update_tx.send(update) {
-                                error!("{:?}", err)
+                                debug!("{:?}", err)
                             };
                             track
                         };
@@ -257,7 +257,7 @@ impl Playback {
                             let queue_update_tx = self.update_tx.clone();
                             let update = StreamUpdate::Queue(queue.clone().into());
                             if let Err(err) = queue_update_tx.send(update) {
-                                error!("{:?}", err)
+                                debug!("{:?}", err)
                             };
                         }
                         debug!("queue lock released");
@@ -279,7 +279,7 @@ impl Playback {
                             let queue_update_tx = self.update_tx.clone();
                             let update = StreamUpdate::Queue(queue.clone().into());
                             if let Err(err) = queue_update_tx.send(update) {
-                                error!("{:?}", err)
+                                debug!("{:?}", err)
                             };
                             should_stop
                         };
@@ -333,7 +333,7 @@ impl Playback {
                         let queue_update_tx = self.update_tx.clone();
                         let update = StreamUpdate::Mods(QueueModifiers { shuffle, repeat });
                         if let Err(err) = queue_update_tx.send(update) {
-                            error!("{:?}", err)
+                            debug!("{:?}", err)
                         }
                     }
 
@@ -360,7 +360,7 @@ impl Playback {
                         let queue_update_tx = self.update_tx.clone();
                         let update = StreamUpdate::Mods(QueueModifiers { shuffle, repeat });
                         if let Err(err) = queue_update_tx.send(update) {
-                            error!("{:?}", err)
+                            debug!("{:?}", err)
                         }
                     }
 
@@ -461,7 +461,7 @@ impl Playback {
                         let active_track_tx = self.update_tx.clone();
                         let update = StreamUpdate::PlayState(play_state as i32);
                         if let Err(err) = active_track_tx.send(update) {
-                            error!("{:?}", err)
+                            debug!("{:?}", err)
                         };
                     }
 
@@ -479,7 +479,7 @@ impl Playback {
                         let update_tx = self.update_tx.clone();
                         let update = StreamUpdate::Volume(volume);
                         if let Err(err) = update_tx.send(update) {
-                            error!("{:?}", err)
+                            debug!("{:?}", err)
                         }
                     }
 
@@ -489,7 +489,7 @@ impl Playback {
                         let update_tx = self.update_tx.clone();
                         let update = StreamUpdate::Mute(muted);
                         if let Err(err) = update_tx.send(update) {
-                            error!("{:?}", err)
+                            debug!("{:?}", err)
                         }
                     }
 
@@ -503,7 +503,7 @@ impl Playback {
                         let update_tx = self.update_tx.clone();
                         let update = StreamUpdate::Position(TrackPosition { duration, position });
                         if let Err(err) = update_tx.send(update) {
-                            error!("{:?}", err)
+                            debug!("{:?}", err)
                         }
                     }
                 }
@@ -611,7 +611,7 @@ impl Playback {
                     track,
                 });
                 if let Err(err) = queue_update_tx.send(update) {
-                    error!("{:?}", err)
+                    debug!("{:?}", err)
                 }
             }
             if let Err(err) = self.player.play(&urls[0]).await {
@@ -658,7 +658,7 @@ impl Playback {
                     track,
                 });
                 if let Err(err) = queue_update_tx.send(update) {
-                    error!("{:?}", err)
+                    debug!("{:?}", err)
                 }
             }
             if let Err(err) = self.player.play(&urls[0]).await {