diff options
| author | Zeyla Hellyer <[email protected]> | 2018-01-18 08:33:27 -0800 |
|---|---|---|
| committer | Zeyla Hellyer <[email protected]> | 2018-01-18 08:33:27 -0800 |
| commit | 9232b8f065deb4637a74e7f85ab617bb527c51be (patch) | |
| tree | 9c2cc2bd6b6238a1bd039e9ad4900e8705197af2 /src/client/dispatch.rs | |
| parent | Fix travis' cache by chmoding $HOME/.cargo (#252) (diff) | |
| download | serenity-9232b8f065deb4637a74e7f85ab617bb527c51be.tar.xz serenity-9232b8f065deb4637a74e7f85ab617bb527c51be.zip | |
Use an InterMessage to communicate over gateway
Instead of communicating over the gateway in a split form of a
`serde_json::Value` or a `client::bridge::gateway::ShardClientMessage`,
wrap them both into a single enum for better interaction between the
client, gateway, and voice modules.
Diffstat (limited to 'src/client/dispatch.rs')
| -rw-r--r-- | src/client/dispatch.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/client/dispatch.rs b/src/client/dispatch.rs index 86ea693..bdd55d6 100644 --- a/src/client/dispatch.rs +++ b/src/client/dispatch.rs @@ -1,9 +1,9 @@ +use gateway::InterMessage; use model::event::Event; use model::channel::{Channel, Message}; use std::sync::Arc; use parking_lot::Mutex; use super::bridge::gateway::event::ClientEvent; -use super::bridge::gateway::ShardClientMessage; use super::event_handler::EventHandler; use super::Context; use std::sync::mpsc::Sender; @@ -40,7 +40,7 @@ macro_rules! now { fn context( data: &Arc<Mutex<ShareMap>>, - runner_tx: &Sender<ShardClientMessage>, + runner_tx: &Sender<InterMessage>, shard_id: u64, ) -> Context { Context::new(Arc::clone(data), runner_tx.clone(), shard_id) @@ -58,7 +58,7 @@ pub(crate) fn dispatch<H: EventHandler + Send + Sync + 'static>( framework: &Arc<Mutex<Option<Box<Framework + Send>>>>, data: &Arc<Mutex<ShareMap>>, event_handler: &Arc<H>, - runner_tx: &Sender<ShardClientMessage>, + runner_tx: &Sender<InterMessage>, threadpool: &ThreadPool, shard_id: u64, ) { @@ -92,7 +92,7 @@ pub(crate) fn dispatch<H: EventHandler + Send + Sync + 'static>( event: DispatchEvent, data: &Arc<Mutex<ShareMap>>, event_handler: &Arc<H>, - runner_tx: &Sender<ShardClientMessage>, + runner_tx: &Sender<InterMessage>, threadpool: &ThreadPool, shard_id: u64, ) { @@ -136,7 +136,7 @@ fn handle_event<H: EventHandler + Send + Sync + 'static>( event: DispatchEvent, data: &Arc<Mutex<ShareMap>>, event_handler: &Arc<H>, - runner_tx: &Sender<ShardClientMessage>, + runner_tx: &Sender<InterMessage>, threadpool: &ThreadPool, shard_id: u64, ) { |