Apply fix for socket_state too (#1627)

This commit is contained in:
Bogdan-Ștefan Neacşu
2022-09-15 17:35:41 +03:00
committed by GitHub
parent 16ef1c547b
commit 3eeda4a421
@@ -113,6 +113,8 @@ impl PartiallyDelegated {
async {
if let Some(mut s) = m_shutdown {
s.recv().await
} else {
std::future::pending::<()>().await
}
}
.fuse()
@@ -121,7 +123,7 @@ impl PartiallyDelegated {
tokio::pin!(shutdown);
#[cfg(target_arch = "wasm32")]
let mut shutdown = Box::pin(async {}.fuse());
let mut shutdown = std::future::pending::<()>().fuse();
let ret_err = loop {
futures::select! {