diff --git a/ohkami/src/layer6_testing/x_websocket.rs b/ohkami/src/layer6_testing/x_websocket.rs index f5fe5c3c..f7da7df2 100644 --- a/ohkami/src/layer6_testing/x_websocket.rs +++ b/ohkami/src/layer6_testing/x_websocket.rs @@ -1,14 +1,12 @@ -use tokio::io::AsyncWriteExt; +use crate::__rt__::AsyncWriter; +use crate::x_websocket::{Config, Message}; -use crate::x_websocket::{Message}; -use crate::x_websocket::{Config}; - -use std::cell::UnsafeCell; use std::pin::Pin; -use std::sync::Arc; +use std::task::Poll; use std::io::{Error}; +use std::cell::UnsafeCell; +use std::sync::Arc; use std::sync::atomic::{AtomicBool, Ordering}; -use std::task::Poll; /// Web socket client for test with upgrade diff --git a/ohkami/src/lib.rs b/ohkami/src/lib.rs index 68b5e17d..82c1ae27 100644 --- a/ohkami/src/lib.rs +++ b/ohkami/src/lib.rs @@ -213,11 +213,11 @@ /*===== async runtime dependency layer =====*/ mod __rt__ { - #[cfg(all(feature="rt_tokio", feature="DEBUG"))] #[allow(unused)] + #[cfg(all(feature="rt_tokio", feature="DEBUG"))] pub(crate) use tokio::test; - #[cfg(all(feature="rt_async-std", feature="DEBUG"))] #[allow(unused)] + #[cfg(all(feature="rt_async-std", feature="DEBUG"))] pub(crate) use async_std::test; #[cfg(feature="rt_tokio")] @@ -232,13 +232,10 @@ mod __rt__ { #[cfg(feature="rt_tokio")] pub(crate) use tokio::sync::Mutex; + #[allow(unused)] #[cfg(feature="rt_async-std")] pub(crate) use async_std::sync::Mutex; - // #[cfg(all(feature="rt_tokio", feature="websocket"))] - // pub(crate) use tokio::net::tcp::{ReadHalf, WriteHalf}; - // /* async-std doesn't have `split` */ - #[cfg(feature="rt_tokio")] pub(crate) use tokio::task; #[cfg(feature="rt_async-std")]