From 8fe65c0e790e15eab8a3009c7ae6eb272a6bf862 Mon Sep 17 00:00:00 2001
From: Jokler <jokler@protonmail.com>
Date: Tue, 14 Jan 2020 04:46:57 +0100
Subject: Use async channel to guarantee tokio never blocks

---
 src/audio_player.rs | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

(limited to 'src/audio_player.rs')

diff --git a/src/audio_player.rs b/src/audio_player.rs
index c4b4b26..68fcc7b 100644
--- a/src/audio_player.rs
+++ b/src/audio_player.rs
@@ -9,8 +9,8 @@ use gstreamer_audio::{StreamVolume, StreamVolumeFormat};
 use crate::{ApplicationMessage, State};
 use glib::BoolError;
 use log::{debug, error, info, warn};
-use std::sync::mpsc::Sender;
 use std::sync::{Arc, Mutex};
+use tokio02::sync::mpsc::UnboundedSender;
 
 static GST_INIT: Once = Once::new();
 
@@ -38,7 +38,7 @@ pub struct AudioPlayer {
     http_src: gst::Element,
 
     volume: gst::Element,
-    sender: Arc<Mutex<Sender<ApplicationMessage>>>,
+    sender: Arc<Mutex<UnboundedSender<ApplicationMessage>>>,
 }
 
 fn make_element(factoryname: &str, display_name: &str) -> Result<gst::Element, AudioPlayerError> {
@@ -87,7 +87,7 @@ fn add_decode_bin_new_pad_callback(
 
 impl AudioPlayer {
     pub fn new(
-        sender: Arc<Mutex<Sender<ApplicationMessage>>>,
+        sender: Arc<Mutex<UnboundedSender<ApplicationMessage>>>,
         callback: Option<Box<dyn FnMut(&[u8]) + Send>>,
     ) -> Result<Self, AudioPlayerError> {
         GST_INIT.call_once(|| gst::init().unwrap());
-- 
cgit v1.2.3-70-g09d2