aboutsummaryrefslogtreecommitdiff
path: root/src/client/bridge/gateway/shard_queuer.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/client/bridge/gateway/shard_queuer.rs')
-rw-r--r--src/client/bridge/gateway/shard_queuer.rs4
1 files changed, 4 insertions, 0 deletions
diff --git a/src/client/bridge/gateway/shard_queuer.rs b/src/client/bridge/gateway/shard_queuer.rs
index f35acb7..ea49de4 100644
--- a/src/client/bridge/gateway/shard_queuer.rs
+++ b/src/client/bridge/gateway/shard_queuer.rs
@@ -14,6 +14,7 @@ use super::{
ShardRunner,
ShardRunnerInfo,
};
+use threadpool::ThreadPool;
use typemap::ShareMap;
#[cfg(feature = "framework")]
@@ -34,6 +35,7 @@ pub struct ShardQueuer<H: EventHandler + Send + Sync + 'static> {
pub manager_tx: Sender<ShardManagerMessage>,
pub runners: Arc<ParkingLotMutex<HashMap<ShardId, ShardRunnerInfo>>>,
pub rx: Receiver<ShardQueuerMessage>,
+ pub threadpool: ThreadPool,
pub token: Arc<Mutex<String>>,
pub ws_url: Arc<Mutex<String>>,
}
@@ -88,6 +90,7 @@ impl<H: EventHandler + Send + Sync + 'static> ShardQueuer<H> {
self.framework.clone(),
self.data.clone(),
self.event_handler.clone(),
+ self.threadpool.clone(),
)
} else {
ShardRunner::new(
@@ -95,6 +98,7 @@ impl<H: EventHandler + Send + Sync + 'static> ShardQueuer<H> {
self.manager_tx.clone(),
self.data.clone(),
self.event_handler.clone(),
+ self.threadpool.clone(),
)
}};