We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ed1ac93 commit a9cfee2Copy full SHA for a9cfee2
1 file changed
crates/hotfix/src/initiator.rs
@@ -63,10 +63,10 @@ impl<M: FixMessage> Initiator<M> {
63
64
pub async fn shutdown(self) -> Result<(), Elapsed> {
65
self.session.shutdown().await;
66
- tokio::time::timeout(Duration::from_secs(5), self.await_shutdown()).await
+ tokio::time::timeout(Duration::from_secs(5), self.wait_for_shutdown()).await
67
}
68
69
- pub async fn await_shutdown(&self) {
+ pub async fn wait_for_shutdown(&self) {
70
let mut rx = self.completion_rx.clone();
71
loop {
72
if *rx.borrow_and_update() {
0 commit comments