This commit is contained in:
Antonio Scandurra 2022-10-12 15:35:28 +02:00
parent ec19f0f8e9
commit c4dde0f4e2

View File

@ -663,7 +663,6 @@ impl Client {
self.set_status(Status::Reconnecting, cx);
}
let mut timeout = cx.background().timer(CONNECTION_TIMEOUT).fuse();
futures::select_biased! {
connection = self.establish_connection(&credentials, cx).fuse() => {
match connection {
@ -696,7 +695,7 @@ impl Client {
}
}
}
_ = timeout => {
_ = cx.background().timer(CONNECTION_TIMEOUT).fuse() => {
self.set_status(Status::ConnectionError, cx);
Err(anyhow!("timed out trying to establish connection"))
}