fix graceful shutdown
This commit is contained in:
parent
47c15d8d43
commit
e3ac4e7b23
|
@ -209,6 +209,7 @@ async fn message_loop<SF>(
|
|||
}
|
||||
}
|
||||
}
|
||||
drop(cancelled_send);
|
||||
let _ = cancelled_recv.recv().await;
|
||||
Ok(())
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue