diff options
Diffstat (limited to 'src/conn.rs')
| -rw-r--r-- | src/conn.rs | 6 |
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"); } } |