aboutsummaryrefslogtreecommitdiff
path: root/src/client/bridge/gateway
diff options
context:
space:
mode:
authoracdenisSK <[email protected]>2018-03-29 12:10:43 +0200
committeracdenisSK <[email protected]>2018-03-29 12:11:23 +0200
commit4c05e828d5191975ef1a5e1ac581b646a69d2c25 (patch)
treefb583f88a1e5d192651b399aca1839f3f58e661e /src/client/bridge/gateway
parentAdd a connection timeout (diff)
downloadserenity-4c05e828d5191975ef1a5e1ac581b646a69d2c25.tar.xz
serenity-4c05e828d5191975ef1a5e1ac581b646a69d2c25.zip
Refactor imports/exports to use nested groups and better formatting
Diffstat (limited to 'src/client/bridge/gateway')
-rw-r--r--src/client/bridge/gateway/mod.rs12
-rw-r--r--src/client/bridge/gateway/shard_manager.rs12
-rw-r--r--src/client/bridge/gateway/shard_manager_monitor.rs6
-rw-r--r--src/client/bridge/gateway/shard_queuer.rs17
-rw-r--r--src/client/bridge/gateway/shard_runner.rs17
-rw-r--r--src/client/bridge/gateway/shard_runner_message.rs8
6 files changed, 51 insertions, 21 deletions
diff --git a/src/client/bridge/gateway/mod.rs b/src/client/bridge/gateway/mod.rs
index 3cc6dca..16f0f07 100644
--- a/src/client/bridge/gateway/mod.rs
+++ b/src/client/bridge/gateway/mod.rs
@@ -63,9 +63,15 @@ pub use self::shard_queuer::ShardQueuer;
pub use self::shard_runner::{ShardRunner, ShardRunnerOptions};
pub use self::shard_runner_message::ShardRunnerMessage;
-use std::fmt::{Display, Formatter, Result as FmtResult};
-use std::sync::mpsc::Sender;
-use std::time::Duration as StdDuration;
+use std::{
+ fmt::{
+ Display,
+ Formatter,
+ Result as FmtResult
+ },
+ sync::mpsc::Sender,
+ time::Duration as StdDuration
+};
use ::gateway::{ConnectionStage, InterMessage};
/// A message either for a [`ShardManager`] or a [`ShardRunner`].
diff --git a/src/client/bridge/gateway/shard_manager.rs b/src/client/bridge/gateway/shard_manager.rs
index b62ff00..a6cea31 100644
--- a/src/client/bridge/gateway/shard_manager.rs
+++ b/src/client/bridge/gateway/shard_manager.rs
@@ -1,10 +1,14 @@
use gateway::InterMessage;
use internal::prelude::*;
use parking_lot::Mutex;
-use std::collections::{HashMap, VecDeque};
-use std::sync::mpsc::{self, Sender};
-use std::sync::Arc;
-use std::thread;
+use std::{
+ collections::{HashMap, VecDeque},
+ sync::{
+ mpsc::{self, Sender},
+ Arc
+ },
+ thread
+};
use super::super::super::EventHandler;
use super::{
ShardClientMessage,
diff --git a/src/client/bridge/gateway/shard_manager_monitor.rs b/src/client/bridge/gateway/shard_manager_monitor.rs
index 9f9c04d..16cc001 100644
--- a/src/client/bridge/gateway/shard_manager_monitor.rs
+++ b/src/client/bridge/gateway/shard_manager_monitor.rs
@@ -1,6 +1,8 @@
use parking_lot::Mutex;
-use std::sync::mpsc::Receiver;
-use std::sync::Arc;
+use std::sync::{
+ mpsc::Receiver,
+ Arc
+};
use super::{ShardManager, ShardManagerMessage};
/// The shard manager monitor does what it says on the tin -- it monitors the
diff --git a/src/client/bridge/gateway/shard_queuer.rs b/src/client/bridge/gateway/shard_queuer.rs
index afcd4c7..edcb6ab 100644
--- a/src/client/bridge/gateway/shard_queuer.rs
+++ b/src/client/bridge/gateway/shard_queuer.rs
@@ -1,11 +1,18 @@
use gateway::Shard;
use internal::prelude::*;
use parking_lot::Mutex;
-use std::collections::{HashMap, VecDeque};
-use std::sync::mpsc::{Receiver, RecvTimeoutError, Sender};
-use std::sync::Arc;
-use std::thread;
-use std::time::{Duration, Instant};
+use std::{
+ collections::{HashMap, VecDeque},
+ sync::{
+ mpsc::{
+ Receiver,
+ RecvTimeoutError,
+ Sender},
+ Arc
+ },
+ thread,
+ time::{Duration, Instant}
+};
use super::super::super::EventHandler;
use super::{
ShardId,
diff --git a/src/client/bridge/gateway/shard_runner.rs b/src/client/bridge/gateway/shard_runner.rs
index 466ce63..4f560e9 100644
--- a/src/client/bridge/gateway/shard_runner.rs
+++ b/src/client/bridge/gateway/shard_runner.rs
@@ -4,16 +4,25 @@ use internal::ws_impl::{ReceiverExt, SenderExt};
use model::event::{Event, GatewayEvent};
use parking_lot::Mutex;
use serde::Deserialize;
-use std::sync::mpsc::{self, Receiver, Sender, TryRecvError};
-use std::sync::Arc;
+use std::sync::{
+ mpsc::{
+ self,
+ Receiver,
+ Sender,
+ TryRecvError
+ },
+ Arc
+};
use super::super::super::dispatch::{DispatchEvent, dispatch};
use super::super::super::EventHandler;
use super::event::{ClientEvent, ShardStageUpdateEvent};
use super::{ShardClientMessage, ShardId, ShardManagerMessage, ShardRunnerMessage};
use threadpool::ThreadPool;
use typemap::ShareMap;
-use websocket::message::{CloseData, OwnedMessage};
-use websocket::WebSocketError;
+use websocket::{
+ message::{CloseData, OwnedMessage},
+ WebSocketError
+};
#[cfg(feature = "framework")]
use framework::Framework;
diff --git a/src/client/bridge/gateway/shard_runner_message.rs b/src/client/bridge/gateway/shard_runner_message.rs
index d4018b4..29024c9 100644
--- a/src/client/bridge/gateway/shard_runner_message.rs
+++ b/src/client/bridge/gateway/shard_runner_message.rs
@@ -1,6 +1,8 @@
-use model::gateway::Game;
-use model::user::OnlineStatus;
-use model::id::GuildId;
+use model::{
+ gateway::Game,
+ user::OnlineStatus,
+ id::GuildId
+};
use websocket::message::OwnedMessage;
/// A message to send from a shard over a WebSocket.