diff options
Diffstat (limited to 'src/client')
| -rw-r--r-- | src/client/bridge/gateway/shard_manager.rs | 4 | ||||
| -rw-r--r-- | src/client/bridge/gateway/shard_manager_monitor.rs | 4 |
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); |