summaryrefslogtreecommitdiffhomepage
path: root/mullvad-cli/src
diff options
context:
space:
mode:
Diffstat (limited to 'mullvad-cli/src')
-rw-r--r--mullvad-cli/src/cmds/tunnel_state.rs44
1 files changed, 22 insertions, 22 deletions
diff --git a/mullvad-cli/src/cmds/tunnel_state.rs b/mullvad-cli/src/cmds/tunnel_state.rs
index d746ae3e86..2db5765f54 100644
--- a/mullvad-cli/src/cmds/tunnel_state.rs
+++ b/mullvad-cli/src/cmds/tunnel_state.rs
@@ -16,15 +16,15 @@ pub async fn connect(wait: bool) -> Result<()> {
None
};
- if rpc.connect_tunnel().await? {
- if let Some(receiver) = listener {
- wait_for_tunnel_state(receiver, |state| match state {
- TunnelState::Connected { .. } => Ok(true),
- TunnelState::Error(_) => Err(anyhow!("Failed to connect")),
- _ => Ok(false),
- })
- .await?;
- }
+ if rpc.connect_tunnel().await?
+ && let Some(receiver) = listener
+ {
+ wait_for_tunnel_state(receiver, |state| match state {
+ TunnelState::Connected { .. } => Ok(true),
+ TunnelState::Error(_) => Err(anyhow!("Failed to connect")),
+ _ => Ok(false),
+ })
+ .await?;
}
Ok(())
@@ -39,10 +39,10 @@ pub async fn disconnect(wait: bool) -> Result<()> {
None
};
- if rpc.disconnect_tunnel().await? {
- if let Some(receiver) = listener {
- wait_for_tunnel_state(receiver, |state| Ok(state.is_disconnected())).await?;
- }
+ if rpc.disconnect_tunnel().await?
+ && let Some(receiver) = listener
+ {
+ wait_for_tunnel_state(receiver, |state| Ok(state.is_disconnected())).await?;
}
Ok(())
@@ -60,15 +60,15 @@ pub async fn reconnect(wait: bool) -> Result<()> {
None
};
- if rpc.reconnect_tunnel().await? {
- if let Some(receiver) = listener {
- wait_for_tunnel_state(receiver, |state| match state {
- TunnelState::Connected { .. } => Ok(true),
- TunnelState::Error(_) => Err(anyhow!("Failed to reconnect")),
- _ => Ok(false),
- })
- .await?;
- }
+ if rpc.reconnect_tunnel().await?
+ && let Some(receiver) = listener
+ {
+ wait_for_tunnel_state(receiver, |state| match state {
+ TunnelState::Connected { .. } => Ok(true),
+ TunnelState::Error(_) => Err(anyhow!("Failed to reconnect")),
+ _ => Ok(false),
+ })
+ .await?;
}
Ok(())