diff options
| author | Linus Färnstrand <linus@mullvad.net> | 2019-12-04 12:16:57 +0100 |
|---|---|---|
| committer | Linus Färnstrand <linus@mullvad.net> | 2019-12-04 12:16:57 +0100 |
| commit | fdf073bde86e90043e3ed35665d702efdc1f844f (patch) | |
| tree | a3e21966c44a01a62d9e7762a0c8ac03801183cd | |
| parent | a4bc0f7a31c1c29486739c079ce17504a514b367 (diff) | |
| parent | 43725ca94a126da60885fbb751b90010b084c169 (diff) | |
| download | mullvadvpn-fdf073bde86e90043e3ed35665d702efdc1f844f.tar.xz mullvadvpn-fdf073bde86e90043e3ed35665d702efdc1f844f.zip | |
Merge branch 'fix-closed-channel-on-connect'
| -rw-r--r-- | mullvad-daemon/src/lib.rs | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/mullvad-daemon/src/lib.rs b/mullvad-daemon/src/lib.rs index d63c28e6a6..e78649ac63 100644 --- a/mullvad-daemon/src/lib.rs +++ b/mullvad-daemon/src/lib.rs @@ -27,7 +27,6 @@ use crate::management_interface::{ BoxFuture, ManagementInterfaceEventBroadcaster, ManagementInterfaceServer, }; use futures::{ - executor, future::{self, Executor}, sync::{mpsc::UnboundedSender, oneshot}, Future, @@ -1511,8 +1510,8 @@ where } fn send_tunnel_command(&mut self, command: TunnelCommand) { - let mut sink = executor::spawn(Arc::make_mut(&mut self.tunnel_command_tx)); - sink.wait_send(command) + self.tunnel_command_tx + .unbounded_send(command) .expect("Tunnel state machine has stopped"); } |
