Fix client connector usage, fixes lifetime constraint

Author: fafhrd91

CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [0.5.1] - 2023-06-23
+
+* Fix client connector usage, fixes lifetime constraint
+
 ## [0.5.0] - 2023-06-22
 
 * Migrate to ntex 0.7

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-redis"
-version = "0.5.0"
+version = "0.5.1"
 authors = ["ntex contributors <[email protected]>"]
 description = "Redis client"
 documentation = "https://docs.rs/ntex-redis"
@@ -12,7 +12,7 @@ exclude = [".gitignore", ".travis.yml", ".cargo/config"]
 edition = "2018"
 
 [dependencies]
-ntex = "0.7.0"
+ntex = "0.7.2"
 itoa = "1.0.0"
 btoi = "0.4.2"
 log = "0.4"
@@ -21,4 +21,4 @@ derive_more = "0.99"
 [dev-dependencies]
 rand = "0.8"
 env_logger = "0.10"
-ntex = { version = "0.7.0", features = ["tokio"] }
+ntex = { version = "0.7.2", features = ["tokio"] }

src/client.rs

@@ -3,7 +3,7 @@ use std::{cell::RefCell, fmt, future::Future, pin::Pin, rc::Rc, task::Context, t
 
 use ntex::io::{IoBoxed, IoRef, OnDisconnect, RecvError};
 use ntex::util::{poll_fn, ready, Either, Ready};
-use ntex::{channel::pool, service::ServiceCtx, service::Service};
+use ntex::{channel::pool, service::Service, service::ServiceCtx};
 
 use super::cmd::Command;
 use super::codec::{Codec, Request, Response};

src/connector.rs

@@ -73,8 +73,11 @@ where
     IoBoxed: From<T::Response>,
 {
     async fn _connect(&self) -> Result<IoBoxed, ConnectError> {
-        let fut = self.connector.call(Connect::new(self.address.clone()));
-        let io = IoBoxed::from(fut.await?);
+        let io: IoBoxed = self
+            .connector
+            .service_call(Connect::new(self.address.clone()))
+            .await?
+            .into();
         io.set_memory_pool(self.pool);
         io.set_disconnect_timeout(Seconds::ZERO.into());