@ -767,7 +767,7 @@ impl Broker {
match already.unwrap().connected {
PeerConnection::NONE => {}
PeerConnection::Client(mut cnx) => {
cnx.close().await;
cnx.close_silently().await;
}
_ => {}
};
@ -1319,6 +1319,17 @@ impl ConnectionBase {
self.send(ConnectionCommand::Close).await;
pub async fn close_silently(&mut self) {
log_debug!("closing silently...");
let _ = self
.shutdown_sender
.take()
.unwrap()
.send(Either::Left(NetError::Closing))
.await;
pub async fn admin<
A: Into<ProtocolMessage>
+ Into<AdminRequestContentV0>