aboutsummaryrefslogtreecommitdiff
path: root/src/client
diff options
context:
space:
mode:
Diffstat (limited to 'src/client')
-rw-r--r--src/client/bridge/gateway/shard_manager.rs4
-rw-r--r--src/client/bridge/gateway/shard_manager_monitor.rs4
2 files changed, 4 insertions, 4 deletions
diff --git a/src/client/bridge/gateway/shard_manager.rs b/src/client/bridge/gateway/shard_manager.rs
index 3bf587c..62629b1 100644
--- a/src/client/bridge/gateway/shard_manager.rs
+++ b/src/client/bridge/gateway/shard_manager.rs
@@ -128,8 +128,8 @@ pub struct ShardManager {
impl ShardManager {
/// Creates a new shard manager, returning both the manager and a monitor
/// for usage in a separate thread.
- pub fn new<'a, H>(
- opt: ShardManagerOptions<'a, H>,
+ pub fn new<H>(
+ opt: ShardManagerOptions<H>,
) -> (Arc<Mutex<Self>>, ShardManagerMonitor) where H: EventHandler + Send + Sync + 'static {
let (thread_tx, thread_rx) = mpsc::channel();
let (shard_queue_tx, shard_queue_rx) = mpsc::channel();
diff --git a/src/client/bridge/gateway/shard_manager_monitor.rs b/src/client/bridge/gateway/shard_manager_monitor.rs
index 16cc001..e9a07cd 100644
--- a/src/client/bridge/gateway/shard_manager_monitor.rs
+++ b/src/client/bridge/gateway/shard_manager_monitor.rs
@@ -46,10 +46,10 @@ impl ShardManagerMonitor {
let manager = self.manager.lock();
let mut runners = manager.runners.lock();
- runners.get_mut(&id).map(|runner| {
+ if let Some(runner) = runners.get_mut(&id) {
runner.latency = latency;
runner.stage = stage;
- });
+ }
}
ShardManagerMessage::Shutdown(shard_id) => {
self.manager.lock().shutdown(shard_id);