aboutsummaryrefslogtreecommitdiff
path: root/src/proto.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/proto.rs')
-rw-r--r--src/proto.rs7
1 files changed, 3 insertions, 4 deletions
diff --git a/src/proto.rs b/src/proto.rs
index d8f6289..ef3b31c 100644
--- a/src/proto.rs
+++ b/src/proto.rs
@@ -3,8 +3,7 @@ use std::sync::Arc;
use log::trace;
-use async_std::io::prelude::WriteExt;
-use async_std::io::ReadExt;
+use futures::{AsyncReadExt, AsyncWriteExt};
use tokio::sync::mpsc;
@@ -94,7 +93,7 @@ pub(crate) trait SendLoop: Sync {
mut write: W,
) -> Result<(), Error>
where
- W: WriteExt + Unpin + Send + Sync,
+ W: AsyncWriteExt + Unpin + Send + Sync,
{
let mut sending = SendQueue::new();
let mut should_exit = false;
@@ -168,7 +167,7 @@ pub(crate) trait RecvLoop: Sync + 'static {
async fn recv_loop<R>(self: Arc<Self>, mut read: R) -> Result<(), Error>
where
- R: ReadExt + Unpin + Send + Sync,
+ R: AsyncReadExt + Unpin + Send + Sync,
{
let mut receiving = HashMap::new();
loop {