Upgrade to ntex 0.5.0 b.2

Author: fafhrd91

CHANGES.md

@@ -1,8 +1,12 @@
 # Changes
 
+## [0.3.0-b.1] - 2021-12-xx
+
+* Upgrade to ntex 0.5.0 b.2
+
 ## [0.3.0-b.0] - 2021-12-19
 
-* upgrade to ntex 0.5
+* Upgrade to ntex 0.5
 
 ## [0.2.4] - 2021-12-02
 

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-redis"
-version = "0.3.0-b.0"
+version = "0.3.0-b.1"
 authors = ["ntex contributors <[email protected]>"]
 description = "Redis client"
 documentation = "https://docs.rs/ntex-redis"
@@ -21,7 +21,7 @@ openssl = ["ntex/openssl"]
 rustls = ["ntex/rustls"]
 
 [dependencies]
-ntex = "0.5.0-b.1"
+ntex = "0.5.0-b.2"
 itoa = "0.4.5"
 btoi = "0.4.2"
 log = "0.4"
@@ -30,3 +30,8 @@ derive_more = "0.99"
 [dev-dependencies]
 rand = "0.8"
 env_logger = "0.9"
+
+[patch.crates-io]
+ntex = { git = "https://github.com/ntex-rs/ntex.git" }
+ntex-io = { git = "https://github.com/ntex-rs/ntex.git" }
+ntex-tls = { git = "https://github.com/ntex-rs/ntex.git" }

src/client.rs

@@ -29,7 +29,7 @@ impl Client {
         let queue2 = queue.clone();
         ntex::rt::spawn(async move {
             poll_fn(|cx| loop {
-                match ready!(io.poll_read_next(&Codec, cx)) {
+                match ready!(io.poll_recv(&Codec, cx)) {
                     Some(Ok(item)) => {
                         if let Some(tx) = queue2.borrow_mut().pop_front() {
                             let _ = tx.send(Ok(item));

src/simple.rs

@@ -24,7 +24,7 @@ impl SimpleClient {
     {
         self.io.encode(cmd.to_request(), &Codec)?;
 
-        poll_fn(|cx| match ready!(self.io.poll_read_next(&Codec, cx)) {
+        poll_fn(|cx| match ready!(self.io.poll_recv(&Codec, cx)) {
             Some(Ok(item)) => Poll::Ready(U::to_output(
                 item.into_result().map_err(CommandError::Error)?,
             )),