wip

ntex-rs · Sep 10, 2024 · a2569b4 · a2569b4
1 parent fc83a88
commit a2569b4
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/ntex-glommio/src/io.rs b/ntex-glommio/src/io.rs
@@ -1,5 +1,5 @@
 use std::task::{Context, Poll};
-use std::{any, future::Future, io, pin::Pin};
+use std::{any, future::poll_fn, future::Future, io, pin::Pin};
 
 use futures_lite::future::FutureExt;
 use futures_lite::io::{AsyncRead, AsyncWrite};
@@ -51,7 +51,7 @@ impl ntex_io::AsyncRead for ReadTask {
     async fn read(&mut self, mut buf: BytesVec) -> (BytesVec, io::Result<usize>) {
         // read data from socket
         let result = poll_fn(|cx| {
-            let mut io = self.0.borrow_mut();
+            let mut io = self.0 .0.borrow_mut();
             poll_read_buf(Pin::new(&mut *io), cx, &mut buf)
         })
         .await;
@@ -324,7 +324,7 @@ impl ntex_io::AsyncRead for UnixReadTask {
     async fn read(&mut self, mut buf: BytesVec) -> (BytesVec, io::Result<usize>) {
         // read data from socket
         let result = poll_fn(|cx| {
-            let mut io = self.0.borrow_mut();
+            let mut io = self.0 .0.borrow_mut();
             poll_read_buf(Pin::new(&mut *io), cx, &mut buf)
         })
         .await;

diff --git a/ntex-net/Cargo.toml b/ntex-net/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ntex-net"
-version = "2.1.0"
+version = "2.2.0"
 authors = ["ntex contributors <[email protected]>"]
 description = "ntexwork utils for ntex framework"
 keywords = ["network", "framework", "async", "futures"]
@@ -34,14 +34,14 @@ async-std = ["ntex-rt/async-std", "ntex-async-std"]
 ntex-service = "3"
 ntex-bytes = "0.1"
 ntex-http = "0.1"
-ntex-io = "2.4"
+ntex-io = "2.5"
 ntex-rt = "0.4.14"
 ntex-util = "2"
 
-ntex-tokio = { version = "0.5.1", optional = true }
-ntex-compio = { version = "0.1", optional = true }
-ntex-glommio = { version = "0.5", optional = true }
-ntex-async-std = { version = "0.5", optional = true }
+ntex-tokio = { version = "0.5.2", optional = true }
+ntex-compio = { version = "0.1.2", optional = true }
+ntex-glommio = { version = "0.5.1", optional = true }
+ntex-async-std = { version = "0.5.1", optional = true }
 
 log = "0.4"
 thiserror = "1"