From a2569b4f0ee34ae3970f81ccfb99649ba023c7de Mon Sep 17 00:00:00 2001 From: Nikolay Kim Date: Tue, 10 Sep 2024 15:52:08 +0500 Subject: [PATCH] wip --- ntex-glommio/src/io.rs | 6 +++--- ntex-net/Cargo.toml | 12 ++++++------ 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/ntex-glommio/src/io.rs b/ntex-glommio/src/io.rs index 8a127f67..d2a953e0 100644 --- 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) { // 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) { // 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 index c53b555e..4f3e5117 100644 --- 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 "] 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"