diff options
| author | acdenisSK <[email protected]> | 2018-03-29 12:10:43 +0200 |
|---|---|---|
| committer | acdenisSK <[email protected]> | 2018-03-29 12:11:23 +0200 |
| commit | 4c05e828d5191975ef1a5e1ac581b646a69d2c25 (patch) | |
| tree | fb583f88a1e5d192651b399aca1839f3f58e661e /src/client/bridge/gateway | |
| parent | Add a connection timeout (diff) | |
| download | serenity-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.rs | 12 | ||||
| -rw-r--r-- | src/client/bridge/gateway/shard_manager.rs | 12 | ||||
| -rw-r--r-- | src/client/bridge/gateway/shard_manager_monitor.rs | 6 | ||||
| -rw-r--r-- | src/client/bridge/gateway/shard_queuer.rs | 17 | ||||
| -rw-r--r-- | src/client/bridge/gateway/shard_runner.rs | 17 | ||||
| -rw-r--r-- | src/client/bridge/gateway/shard_runner_message.rs | 8 |
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. |