commit
2df2d09e3c
1 changed files with 3 additions and 8 deletions
|
@ -128,15 +128,10 @@ impl Room {
|
|||
let url = url.to_string();
|
||||
let token = token.to_string();
|
||||
async move {
|
||||
match rx.await.unwrap().context("error connecting to room") {
|
||||
Ok(()) => {
|
||||
*this.connection.lock().0.borrow_mut() =
|
||||
ConnectionState::Connected { url, token };
|
||||
rx.await.unwrap().context("error connecting to room")?;
|
||||
*this.connection.lock().0.borrow_mut() = ConnectionState::Connected { url, token };
|
||||
Ok(())
|
||||
}
|
||||
Err(err) => Err(err),
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
fn did_disconnect(&self) {
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue