diff options
author | Alex Auvolat <alex@adnab.me> | 2021-10-12 14:51:28 +0200 |
---|---|---|
committer | Alex Auvolat <alex@adnab.me> | 2021-10-12 14:51:28 +0200 |
commit | a4069d703c63e9512a87df7f16c574711f960335 (patch) | |
tree | dac67bf63ba2c85c421d3d10b9dbf71d9d32e4e2 /src/proto.rs | |
parent | b14515a422a04fa008e6c67f6465ead927c7b8ad (diff) | |
download | netapp-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.rs | 7 |
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 { |