bugfix: break when message is sent sucessfully
This commit is contained in:
parent
4816f43bea
commit
0fc8947ac8
|
@ -146,6 +146,7 @@ impl ConnectionManager {
|
|||
match send_message(send_stream, message.clone()).await {
|
||||
Ok(_) => {
|
||||
log::debug!("Message sucessfully sent");
|
||||
break;
|
||||
}
|
||||
Err(e) => {
|
||||
log::error!(
|
||||
|
|
|
@ -43,7 +43,7 @@ pub enum ChannelMessage {
|
|||
|
||||
#[derive(Debug)]
|
||||
pub struct QuicServer {
|
||||
runtime: Runtime,
|
||||
_runtime: Runtime,
|
||||
data_channel_sender: UnboundedSender<ChannelMessage>,
|
||||
}
|
||||
|
||||
|
@ -126,12 +126,13 @@ impl QuicServer {
|
|||
}
|
||||
}
|
||||
}
|
||||
log::error!("quic server dispatch task stopped");
|
||||
});
|
||||
}
|
||||
|
||||
Ok(QuicServer {
|
||||
data_channel_sender,
|
||||
runtime,
|
||||
_runtime: runtime,
|
||||
})
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue