Upgrade to tokio 1.0

1 files changed, 3 insertions, 3 deletions

diff --git a/src/conn.rs b/src/conn.rs
index daa0235..6c5f38a 100644
--- a/src/conn.rs
+++ b/src/conn.rs
@@ -102,7 +102,7 @@ impl ServerConn {
 	}
 
 	pub fn close(&self) {
-		self.close_send.broadcast(true).unwrap();
+		self.close_send.send(true).unwrap();
 	}
 }
 
@@ -217,7 +217,7 @@ impl ClientConn {
 			.log_err("could not write None in query_send");
 		if self.inflight.lock().unwrap().is_empty() {
 			self.stop_recv_loop
-				.broadcast(true)
+				.send(true)
 				.log_err("could not write true to stop_recv_loop");
 		}
 	}
@@ -274,7 +274,7 @@ impl RecvLoop for ClientConn {
 
 		if inflight.is_empty() && self.must_exit.load(atomic::Ordering::SeqCst) {
 			self.stop_recv_loop
-				.broadcast(true)
+				.send(true)
 				.log_err("could not write true to stop_recv_loop");
 		}
 	}