Stowage/noita_entangled_worlds
2
0
Fork 0
mirror of https://github.com/IntQuant/noita_entangled_worlds.git synced 2025-10-19 07:03:16 +00:00
Code Issues Projects Releases Packages Wiki Activity

Make tests pass

Browse source
This commit is contained in:
IQuant 2024-09-06 21:06:27 +03:00
parent f4b5eef5fb
commit b2efc56adc
1 changed files with 7 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

8
noita-proxy/tangled/src/connection_manager.rs
View file

@ -5,6 +5,7 @@ use std::{
atomic::{AtomicBool, Ordering},
Arc,
},
time::Duration,
};
use bitcode::{Decode, Encode};
@ -429,9 +430,14 @@ impl ConnectionManager {
let ev = ev.expect("channel to not be closed");
self.handle_internal_event(ev).await;
}
// Check if we need to stop periodically.
_ = tokio::time::sleep(Duration::from_millis(1000)) => {}
}
}
debug!("Closing endpoint");
self.endpoint
.close(0u32.into(), b"peer decided to disconnect");
}
pub(crate) fn start(self) -> Result<(), TangledInitError> {