Debug
This commit is contained in:
parent
9d8ec183a2
commit
93403d781b
1 changed files with 9 additions and 9 deletions
|
|
@ -144,15 +144,15 @@ impl Handler {
|
|||
}
|
||||
|
||||
}
|
||||
message = receive_message.recv() => {
|
||||
info!("Received a message through the channel");
|
||||
match message {
|
||||
Some(message) => {
|
||||
let _ = self.connection.write_frame(message).await;
|
||||
},
|
||||
None => (),
|
||||
}
|
||||
}
|
||||
// message = receive_message.recv() => {
|
||||
// info!("Received a message through the channel");
|
||||
// match message {
|
||||
// Some(message) => {
|
||||
// let _ = self.connection.write_frame(message).await;
|
||||
// },
|
||||
// None => (),
|
||||
// }
|
||||
// }
|
||||
_ = self.shutdown.recv() => {
|
||||
debug!("Shutdown");
|
||||
return Ok(());
|
||||
|
|
|
|||
Loading…
Reference in a new issue