From f7fe187c464525339c58996ec86b4faea4306789 Mon Sep 17 00:00:00 2001
From: Yuval Adam <_@yuv.al>
Date: Tue, 4 Jun 2024 20:59:56 +0200
Subject: Use unbounded mpsc channel

---
 src/audio/rodio.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'src/audio/rodio.rs')

diff --git a/src/audio/rodio.rs b/src/audio/rodio.rs
index 695c6cb..f5ad5cc 100644
--- a/src/audio/rodio.rs
+++ b/src/audio/rodio.rs
@@ -13,7 +13,7 @@ const AUDIO_BUFFER_SECONDS: u32 = 5;
 pub struct Rodio {}
 
 impl Rodio {
-    pub async fn play(&self, url: &str, tx: mpsc::Sender<String>) {
+    pub async fn play(&self, url: &str, tx: mpsc::UnboundedSender<String>) {
         let (_stream, handle) = OutputStream::try_default().unwrap();
         let sink = Sink::try_new(&handle).unwrap();
 
@@ -57,7 +57,7 @@ impl Rodio {
                     }
                 },
             ))
-            .unwrap(),
+            .expect("Failed to play stream, check network and try again later"),
         );
 
         let handle = tokio::task::spawn_blocking(move || {
-- 
cgit v1.3.1