aboutsummaryrefslogtreecommitdiff
path: root/src/proto.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2021-10-12 14:51:28 +0200
committerAlex Auvolat <alex@adnab.me>2021-10-12 14:51:28 +0200
commita4069d703c63e9512a87df7f16c574711f960335 (patch)
treedac67bf63ba2c85c421d3d10b9dbf71d9d32e4e2 /src/proto.rs
parentb14515a422a04fa008e6c67f6465ead927c7b8ad (diff)
downloadnetapp-a4069d703c63e9512a87df7f16c574711f960335.tar.gz
netapp-a4069d703c63e9512a87df7f16c574711f960335.zip
Use tokio_util::compat instead of the one from kuska-handshake
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 {