Skip to content
This repository has been archived by the owner on Aug 3, 2023. It is now read-only.

Commit

Permalink
chore: update other send failures to log errors
Browse files Browse the repository at this point in the history
  • Loading branch information
Steve Manuel committed Sep 14, 2021
1 parent f2c6e1d commit 52d86e9
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 5 deletions.
5 changes: 3 additions & 2 deletions src/commands/dev/edge/server/http.rs
Original file line number Diff line number Diff line change
Expand Up @@ -85,8 +85,9 @@ pub async fn http(
if let Err(e) = server.await {
eprintln!("{}", e);
}
tx.send(())
.expect("Could not acknowledge listener shutdown");
if let Err(e) = tx.send(()) {
log::error!("Could not acknowledge dev http listener shutdown: {:?}", e);
}

Ok(())
}
5 changes: 3 additions & 2 deletions src/commands/dev/edge/server/https.rs
Original file line number Diff line number Diff line change
Expand Up @@ -119,8 +119,9 @@ pub async fn https(
if let Err(e) = server.await {
eprintln!("{}", e);
}
tx.send(())
.expect("Could not acknowledge listener shutdown");
if let Err(e) = tx.send(()) {
log::error!("Could not acknowledge dev https listener shutdown: {:?}", e);
}

Ok(())
}
4 changes: 3 additions & 1 deletion src/commands/dev/socket.rs
Original file line number Diff line number Diff line change
Expand Up @@ -421,7 +421,9 @@ async fn keep_alive(tx: mpsc::UnboundedSender<tungstenite::protocol::Message>) -
let keep_alive_message = serde_json::to_string(&keep_alive_message)
.expect("Could not convert keep alive message to JSON");
let keep_alive_message = tungstenite::protocol::Message::Text(keep_alive_message);
tx.send(keep_alive_message).unwrap();
if let Err(e) = tx.send(keep_alive_message) {
log::error!("failed to send keepalive message: {}", e);
}
id += 1;
delay = sleep(duration);
}
Expand Down

0 comments on commit 52d86e9

Please sign in to comment.