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/teamspeak.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'src/teamspeak.rs')

diff --git a/src/teamspeak.rs b/src/teamspeak.rs
index 2cd87e7..79dc1bc 100644
--- a/src/teamspeak.rs
+++ b/src/teamspeak.rs
@@ -1,8 +1,8 @@
 use futures::compat::Future01CompatExt;
 use futures01::{future::Future, sink::Sink};
+use tokio02::sync::mpsc::UnboundedSender;
 
 use crate::{ApplicationMessage, Message};
-use std::sync::mpsc::Sender;
 use std::sync::{Arc, Mutex};
 use tsclientlib::Event::ConEvents;
 use tsclientlib::{events::Event, ClientId, ConnectOptions, Connection, MessageTarget};
@@ -30,7 +30,7 @@ fn get_message<'a>(event: &Event) -> Option<Message> {
 
 impl TeamSpeakConnection {
     pub async fn new(
-        tx: Arc<Mutex<Sender<ApplicationMessage>>>,
+        tx: Arc<Mutex<UnboundedSender<ApplicationMessage>>>,
         options: ConnectOptions,
     ) -> Result<TeamSpeakConnection, tsclientlib::Error> {
         let conn = Connection::new(options).compat().await?;
-- 
cgit v1.2.3-70-g09d2