aboutsummaryrefslogtreecommitdiff
path: root/src/client/bridge/gateway/shard_queuer.rs
diff options
context:
space:
mode:
authoracdenisSK <[email protected]>2017-10-14 22:41:25 +0200
committeracdenisSK <[email protected]>2017-10-14 22:41:25 +0200
commitcae014758a1d1e926a71679f02e32601c57f8d52 (patch)
tree39270dbc2df916a91c3c4272600fd082a2604516 /src/client/bridge/gateway/shard_queuer.rs
parentSwitch to parking_lot::{Mutex, RwLock} (diff)
parentRelease v0.4.1 (diff)
downloadserenity-cae014758a1d1e926a71679f02e32601c57f8d52.tar.xz
serenity-cae014758a1d1e926a71679f02e32601c57f8d52.zip
Update to account for changes made in 0.4.1
Diffstat (limited to 'src/client/bridge/gateway/shard_queuer.rs')
-rw-r--r--src/client/bridge/gateway/shard_queuer.rs14
1 files changed, 9 insertions, 5 deletions
diff --git a/src/client/bridge/gateway/shard_queuer.rs b/src/client/bridge/gateway/shard_queuer.rs
index f75e35d..cb3f749 100644
--- a/src/client/bridge/gateway/shard_queuer.rs
+++ b/src/client/bridge/gateway/shard_queuer.rs
@@ -80,16 +80,20 @@ impl<H: EventHandler + Send + Sync + 'static> ShardQueuer<H> {
fn start(&mut self, shard_id: ShardId, shard_total: ShardId) -> Result<()> {
let shard_info = [shard_id.0, shard_total.0];
- let shard = Shard::new(self.ws_url.clone(), self.token.clone(), shard_info)?;
+ let shard = Shard::new(
+ Arc::clone(&self.ws_url),
+ Arc::clone(&self.token),
+ shard_info,
+ )?;
let locked = Arc::new(Mutex::new(shard));
let mut runner = feature_framework! {{
ShardRunner::new(
- locked.clone(),
+ Arc::clone(&locked),
self.manager_tx.clone(),
- self.framework.clone(),
- self.data.clone(),
- self.event_handler.clone(),
+ Arc::clone(&self.framework),
+ Arc::clone(&self.data),
+ Arc::clone(&self.event_handler),
self.threadpool.clone(),
)
} else {