chore: use order
This commit is contained in:
@@ -10,6 +10,7 @@ use std::io::Error as IoError;
|
|||||||
use std::collections::{HashMap, BTreeMap};
|
use std::collections::{HashMap, BTreeMap};
|
||||||
use std::net::SocketAddr;
|
use std::net::SocketAddr;
|
||||||
use std::sync::Mutex;
|
use std::sync::Mutex;
|
||||||
|
use std::sync::atomic::{AtomicU64, Ordering};
|
||||||
use futures_channel::mpsc::unbounded;
|
use futures_channel::mpsc::unbounded;
|
||||||
use futures_util::{future, pin_mut, stream::TryStreamExt, StreamExt};
|
use futures_util::{future, pin_mut, stream::TryStreamExt, StreamExt};
|
||||||
use tokio::net::{TcpListener, TcpStream};
|
use tokio::net::{TcpListener, TcpStream};
|
||||||
@@ -21,7 +22,6 @@ use crate::slash_handles::{HandleContext, HandleTextMessage, HandleTextMessageTi
|
|||||||
use crate::slash_handles::{HandleTextMessageExit, HandleTextMessageStatics};
|
use crate::slash_handles::{HandleTextMessageExit, HandleTextMessageStatics};
|
||||||
use crate::slash_handles::{HandleTextMessagePass, HandleTextMessageRoom};
|
use crate::slash_handles::{HandleTextMessagePass, HandleTextMessageRoom};
|
||||||
use crate::slash_handles::{HandleTextMessageRooms, HandleTextMessageVersion};
|
use crate::slash_handles::{HandleTextMessageRooms, HandleTextMessageVersion};
|
||||||
use std::sync::atomic::{AtomicU64, Ordering};
|
|
||||||
|
|
||||||
const NAME: &str = env!("CARGO_PKG_NAME");
|
const NAME: &str = env!("CARGO_PKG_NAME");
|
||||||
const VERSION: &str = env!("CARGO_PKG_VERSION");
|
const VERSION: &str = env!("CARGO_PKG_VERSION");
|
||||||
|
|||||||
@@ -1,9 +1,9 @@
|
|||||||
use crate::types::{PeerMap, RoomMap, Tx, TxSendMessage};
|
|
||||||
use std::net::SocketAddr;
|
use std::net::SocketAddr;
|
||||||
|
use std::sync::atomic::Ordering;
|
||||||
use chrono::Local;
|
use chrono::Local;
|
||||||
use crate::msg::RoomMessageDown;
|
use crate::msg::RoomMessageDown;
|
||||||
|
use crate::types::{PeerMap, RoomMap, Tx, TxSendMessage};
|
||||||
use crate::{NAME, VERSION, TOTAL_CREATED_CONN};
|
use crate::{NAME, VERSION, TOTAL_CREATED_CONN};
|
||||||
use std::sync::atomic::Ordering;
|
|
||||||
|
|
||||||
#[derive(Debug, Clone)]
|
#[derive(Debug, Clone)]
|
||||||
pub struct HandleContext {
|
pub struct HandleContext {
|
||||||
|
|||||||
@@ -1,8 +1,8 @@
|
|||||||
use futures_channel::mpsc::UnboundedSender;
|
|
||||||
use tungstenite::Message;
|
|
||||||
use std::net::SocketAddr;
|
use std::net::SocketAddr;
|
||||||
use std::collections::{HashMap, BTreeMap};
|
use std::collections::{HashMap, BTreeMap};
|
||||||
use std::sync::{Mutex, Arc};
|
use std::sync::{Mutex, Arc};
|
||||||
|
use futures_channel::mpsc::UnboundedSender;
|
||||||
|
use tungstenite::Message;
|
||||||
|
|
||||||
pub type Tx = UnboundedSender<Message>;
|
pub type Tx = UnboundedSender<Message>;
|
||||||
pub type PeerMap = Arc<Mutex<HashMap<SocketAddr, Tx>>>;
|
pub type PeerMap = Arc<Mutex<HashMap<SocketAddr, Tx>>>;
|
||||||
|
|||||||
Reference in New Issue
Block a user