GRIN/nym
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

first pass all fns

Browse Source
This commit is contained in:
mfahampshire
2024-12-19 13:41:00 +01:00
parent d7d2aaff68
commit b6b8ec41eb
1 changed files with 9 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tools/echo-server/src/lib.rs
+9 -12
View File
@@ -159,18 +159,15 @@ impl NymEchoServer {
info!("Connection closed");
}
// TODO
// - make disconnect for proxy_server
// - make disconnect for this
// pub async fn disconnect(&self) {
// self.cancel_token.cancel();
// let client = Arc::clone(&self.client);
// client.lock().await.disconnect_pool().await;
// while metrics.active_conn.load(Ordering::Relaxed) > 0 {
// info!("Waiting on active connections to close: sleeping 100ms");
// tokio::time::sleep(tokio::time::Duration::from_millis(100)).await;
// }
// }
pub async fn disconnect(&self) {
self.cancel_token.cancel();
let client = Arc::clone(&self.client);
client.lock().await.disconnect().await;
while self.metrics.active_conn.load(Ordering::Relaxed) > 0 {
info!("Waiting on active connections to close: sleeping 100ms");
tokio::time::sleep(tokio::time::Duration::from_millis(100)).await;
}
}
pub fn nym_address(&self) -> Recipient {
self.client_address