aboutsummaryrefslogtreecommitdiff
path: root/src/client/bridge/gateway/shard_messenger.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/client/bridge/gateway/shard_messenger.rs')
-rw-r--r--src/client/bridge/gateway/shard_messenger.rs9
1 files changed, 5 insertions, 4 deletions
diff --git a/src/client/bridge/gateway/shard_messenger.rs b/src/client/bridge/gateway/shard_messenger.rs
index a4b63f3..b2a5ce1 100644
--- a/src/client/bridge/gateway/shard_messenger.rs
+++ b/src/client/bridge/gateway/shard_messenger.rs
@@ -1,3 +1,4 @@
+use gateway::InterMessage;
use model::prelude::*;
use super::{ShardClientMessage, ShardRunnerMessage};
use std::sync::mpsc::{SendError, Sender};
@@ -14,7 +15,7 @@ use websocket::message::OwnedMessage;
/// [`shutdown`]: #method.shutdown
#[derive(Clone, Debug)]
pub struct ShardMessenger {
- tx: Sender<ShardClientMessage>,
+ tx: Sender<InterMessage>,
}
impl ShardMessenger {
@@ -24,7 +25,7 @@ impl ShardMessenger {
///
/// [`Client`]: ../../struct.Client.html
#[inline]
- pub fn new(tx: Sender<ShardClientMessage>) -> Self {
+ pub fn new(tx: Sender<InterMessage>) -> Self {
Self {
tx,
}
@@ -270,7 +271,7 @@ impl ShardMessenger {
#[inline]
fn send(&self, msg: ShardRunnerMessage)
- -> Result<(), SendError<ShardClientMessage>> {
- self.tx.send(ShardClientMessage::Runner(msg))
+ -> Result<(), SendError<InterMessage>> {
+ self.tx.send(InterMessage::Client(ShardClientMessage::Runner(msg)))
}
}