diff options
| author | Linus Färnstrand <linus@mullvad.net> | 2017-09-01 15:37:58 +0200 |
|---|---|---|
| committer | Linus Färnstrand <linus@mullvad.net> | 2017-09-01 15:37:58 +0200 |
| commit | db19f0c33aa3f9ec2b04e22bc54edd274aed4cd3 (patch) | |
| tree | 3802756a082e8070fa45bbfc230d168522574646 | |
| parent | 6cc0c78b5e91de148d2955db572e5ec8fc863e4a (diff) | |
| download | mullvadvpn-db19f0c33aa3f9ec2b04e22bc54edd274aed4cd3.tar.xz mullvadvpn-db19f0c33aa3f9ec2b04e22bc54edd274aed4cd3.zip | |
Replace boxed() with Box::new()
| -rw-r--r-- | mullvad-daemon/src/main.rs | 5 | ||||
| -rw-r--r-- | mullvad-daemon/src/management_interface.rs | 33 |
2 files changed, 19 insertions, 19 deletions
diff --git a/mullvad-daemon/src/main.rs b/mullvad-daemon/src/main.rs index 4551b19b7f..deb3d184f2 100644 --- a/mullvad-daemon/src/main.rs +++ b/mullvad-daemon/src/main.rs @@ -317,9 +317,8 @@ impl Daemon { account_token: AccountToken) { let rpc_call = self.accounts_proxy .get_expiry(account_token) - .map(|expiry| AccountData { expiry }) - .boxed(); - Self::oneshot_send(tx, rpc_call, "account data") + .map(|expiry| AccountData { expiry }); + Self::oneshot_send(tx, Box::new(rpc_call), "account data") } diff --git a/mullvad-daemon/src/management_interface.rs b/mullvad-daemon/src/management_interface.rs index 62b1994773..47a2c81d33 100644 --- a/mullvad-daemon/src/management_interface.rs +++ b/mullvad-daemon/src/management_interface.rs @@ -232,14 +232,15 @@ impl<T: From<TunnelCommand> + 'static + Send> ManagementInterface<T> { }, ) }; - result.boxed() + Box::new(result) } /// Sends a command to the daemon and maps the error to an RPC error. fn send_command_to_daemon(&self, command: TunnelCommand) -> BoxFuture<(), Error> { - future::result(self.tx.lock().unwrap().send(command)) - .map_err(|_| Error::internal_error()) - .boxed() + Box::new( + future::result(self.tx.lock().unwrap().send(command)) + .map_err(|_| Error::internal_error()) + ) } } @@ -249,10 +250,10 @@ impl<T: From<TunnelCommand> + 'static + Send> ManagementInterfaceApi for Managem fn get_account_data(&self, account_token: AccountToken) -> BoxFuture<AccountData, Error> { trace!("get_account_data"); let (tx, rx) = sync::oneshot::channel(); - self.send_command_to_daemon(TunnelCommand::GetAccountData(tx, account_token)) + let future = self.send_command_to_daemon(TunnelCommand::GetAccountData(tx, account_token)) .and_then(|_| rx.map_err(|_| Error::internal_error())) - .and_then(|rpc_future| rpc_future.map_err(|_| Error::internal_error())) - .boxed() + .and_then(|rpc_future| rpc_future.map_err(|_| Error::internal_error())); + Box::new(future) } fn get_countries(&self) -> Result<HashMap<CountryCode, String>, Error> { @@ -263,17 +264,17 @@ impl<T: From<TunnelCommand> + 'static + Send> ManagementInterfaceApi for Managem fn set_account(&self, account_token: Option<AccountToken>) -> BoxFuture<(), Error> { trace!("set_account"); let (tx, rx) = sync::oneshot::channel(); - self.send_command_to_daemon(TunnelCommand::SetAccount(tx, account_token)) - .and_then(|_| rx.map_err(|_| Error::internal_error())) - .boxed() + let future = self.send_command_to_daemon(TunnelCommand::SetAccount(tx, account_token)) + .and_then(|_| rx.map_err(|_| Error::internal_error())); + Box::new(future) } fn get_account(&self) -> BoxFuture<Option<AccountToken>, Error> { trace!("get_account"); let (tx, rx) = sync::oneshot::channel(); - self.send_command_to_daemon(TunnelCommand::GetAccount(tx)) - .and_then(|_| rx.map_err(|_| Error::internal_error())) - .boxed() + let future = self.send_command_to_daemon(TunnelCommand::GetAccount(tx)) + .and_then(|_| rx.map_err(|_| Error::internal_error())); + Box::new(future) } fn set_country(&self, _country_code: CountryCode) -> Result<(), Error> { @@ -299,9 +300,9 @@ impl<T: From<TunnelCommand> + 'static + Send> ManagementInterfaceApi for Managem fn get_state(&self) -> BoxFuture<DaemonState, Error> { trace!("get_state"); let (state_tx, state_rx) = sync::oneshot::channel(); - self.send_command_to_daemon(TunnelCommand::GetState(state_tx)) - .and_then(|_| state_rx.map_err(|_| Error::internal_error())) - .boxed() + let future = self.send_command_to_daemon(TunnelCommand::GetState(state_tx)) + .and_then(|_| state_rx.map_err(|_| Error::internal_error())); + Box::new(future) } fn get_ip(&self) -> Result<IpAddr, Error> { |
