clusterfuck
/
crabidy
4
1
Fork 0
Code Issues 15 Pull Requests Actions Packages Projects 1 Releases 5 Wiki Activity

Don't error on failing broadcast channel send
CI checks / stable / fmt (push) Successful in 3s Details

This commit is contained in:
Hans Mündelein 2023-06-14 11:19:11 +02:00
parent 6db11131c0
commit e147f90168
Signed by: hans
GPG Key ID: BA7B55E984CE74F4
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
crabidy-server/src/playback.rs
View File

@ -120,7 +120,7 @@ impl Playback {
let queue_update_tx = self.update_tx.clone(); let queue_update_tx = self.update_tx.clone();
let update = StreamUpdate::Queue(queue.clone().into()); let update = StreamUpdate::Queue(queue.clone().into());
if let Err(err) = queue_update_tx.send(update) { if let Err(err) = queue_update_tx.send(update) {
error!("{:?}", err) debug!("{:?}", err)
}; };
queue.current_track() queue.current_track()
}; };
@ -153,7 +153,7 @@ impl Playback {
let queue_update_tx = self.update_tx.clone(); let queue_update_tx = self.update_tx.clone();
let update = StreamUpdate::Queue(queue.clone().into()); let update = StreamUpdate::Queue(queue.clone().into());
if let Err(err) = queue_update_tx.send(update) { if let Err(err) = queue_update_tx.send(update) {
error!("{:?}", err) debug!("{:?}", err)
} }
} }
debug!("que lock released"); debug!("que lock released");
@ -184,7 +184,7 @@ impl Playback {
let queue_update_tx = self.update_tx.clone(); let queue_update_tx = self.update_tx.clone();
let update = StreamUpdate::Queue(queue.clone().into()); let update = StreamUpdate::Queue(queue.clone().into());
if let Err(err) = queue_update_tx.send(update) { if let Err(err) = queue_update_tx.send(update) {
error!("{:?}", err) debug!("{:?}", err)
} }
} }
debug!("queue lock released"); debug!("queue lock released");
@ -205,7 +205,7 @@ impl Playback {
let queue_update_tx = self.update_tx.clone(); let queue_update_tx = self.update_tx.clone();
let update = StreamUpdate::Queue(queue.clone().into()); let update = StreamUpdate::Queue(queue.clone().into());
if let Err(err) = queue_update_tx.send(update) { if let Err(err) = queue_update_tx.send(update) {
error!("{:?}", err) debug!("{:?}", err)
}; };
track track
}; };
@ -257,7 +257,7 @@ impl Playback {
let queue_update_tx = self.update_tx.clone(); let queue_update_tx = self.update_tx.clone();
let update = StreamUpdate::Queue(queue.clone().into()); let update = StreamUpdate::Queue(queue.clone().into());
if let Err(err) = queue_update_tx.send(update) { if let Err(err) = queue_update_tx.send(update) {
error!("{:?}", err) debug!("{:?}", err)
}; };
} }
debug!("queue lock released"); debug!("queue lock released");
@ -279,7 +279,7 @@ impl Playback {
let queue_update_tx = self.update_tx.clone(); let queue_update_tx = self.update_tx.clone();
let update = StreamUpdate::Queue(queue.clone().into()); let update = StreamUpdate::Queue(queue.clone().into());
if let Err(err) = queue_update_tx.send(update) { if let Err(err) = queue_update_tx.send(update) {
error!("{:?}", err) debug!("{:?}", err)
}; };
should_stop should_stop
}; };
@ -333,7 +333,7 @@ impl Playback {
let queue_update_tx = self.update_tx.clone(); let queue_update_tx = self.update_tx.clone();
let update = StreamUpdate::Mods(QueueModifiers { shuffle, repeat }); let update = StreamUpdate::Mods(QueueModifiers { shuffle, repeat });
if let Err(err) = queue_update_tx.send(update) { 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 queue_update_tx = self.update_tx.clone();
let update = StreamUpdate::Mods(QueueModifiers { shuffle, repeat }); let update = StreamUpdate::Mods(QueueModifiers { shuffle, repeat });
if let Err(err) = queue_update_tx.send(update) { 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 active_track_tx = self.update_tx.clone();
let update = StreamUpdate::PlayState(play_state as i32); let update = StreamUpdate::PlayState(play_state as i32);
if let Err(err) = active_track_tx.send(update) { 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_tx = self.update_tx.clone();
let update = StreamUpdate::Volume(volume); let update = StreamUpdate::Volume(volume);
if let Err(err) = update_tx.send(update) { 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_tx = self.update_tx.clone();
let update = StreamUpdate::Mute(muted); let update = StreamUpdate::Mute(muted);
if let Err(err) = update_tx.send(update) { 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_tx = self.update_tx.clone();
let update = StreamUpdate::Position(TrackPosition { duration, position }); let update = StreamUpdate::Position(TrackPosition { duration, position });
if let Err(err) = update_tx.send(update) { if let Err(err) = update_tx.send(update) {
error!("{:?}", err) debug!("{:?}", err)
} }
} }
} }
@ -611,7 +611,7 @@ impl Playback {
track, track,
}); });
if let Err(err) = queue_update_tx.send(update) { if let Err(err) = queue_update_tx.send(update) {
error!("{:?}", err) debug!("{:?}", err)
} }
} }
if let Err(err) = self.player.play(&urls[0]).await { if let Err(err) = self.player.play(&urls[0]).await {
@ -658,7 +658,7 @@ impl Playback {
track, track,
}); });
if let Err(err) = queue_update_tx.send(update) { if let Err(err) = queue_update_tx.send(update) {
error!("{:?}", err) debug!("{:?}", err)
} }
} }
if let Err(err) = self.player.play(&urls[0]).await { if let Err(err) = self.player.play(&urls[0]).await {