Fix lifetimes for unix_connect/unix_connect_in

ntex-rt/CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [0.4.0-b.1] - 2021-12-xx
+
+* Fix lifetimes for unix_connect/unix_connect_in
+
 ## [0.3.2] - 2021-12-10
 
 * Set spawn fn to ntex-util

ntex-rt/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-rt"
-version = "0.4.0-b.0"
+version = "0.4.0-b.1"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "ntex runtime"
 keywords = ["network", "framework", "async", "futures"]
@@ -23,7 +23,7 @@ tokio = ["tok-io", "ntex-io/tokio"]
 
 [dependencies]
 ntex-bytes = "0.1.8"
-ntex-io = "0.1.0-b.1"
+ntex-io = "0.1.0-b.3"
 ntex-util = "0.1.3"
 async-oneshot = "0.5.0"
 async-channel = "1.6.1"

ntex-rt/src/tokio.rs

@@ -41,9 +41,11 @@ pub fn tcp_connect_in(
 
 #[cfg(unix)]
 /// Opens a unix stream connection.
-pub fn unix_connect<P>(addr: P) -> Pin<Box<dyn Future<Output = Result<Io, io::Error>>>>
+pub fn unix_connect<'a, P>(
+    addr: P,
+) -> Pin<Box<dyn Future<Output = Result<Io, io::Error>> + 'a>>
 where
-    P: AsRef<Path> + 'static,
+    P: AsRef<Path> + 'a,
 {
     Box::pin(async move {
         let sock = tok_io::net::UnixStream::connect(addr).await?;
@@ -51,6 +53,21 @@ where
     })
 }
 
+#[cfg(unix)]
+/// Opens a unix stream connection and specified memory pool.
+pub fn unix_connect_in<'a, P>(
+    addr: P,
+    pool: PoolRef,
+) -> Pin<Box<dyn Future<Output = Result<Io, io::Error>> + 'a>>
+where
+    P: AsRef<Path> + 'a,
+{
+    Box::pin(async move {
+        let sock = tok_io::net::UnixStream::connect(addr).await?;
+        Ok(Io::with_memory_pool(sock, pool))
+    })
+}
+
 /// Convert std TcpStream to tokio's TcpStream
 pub fn from_tcp_stream(stream: net::TcpStream) -> Result<Io, io::Error> {
     stream.set_nonblocking(true)?;

ntex/Cargo.toml

@@ -47,7 +47,7 @@ ntex-util = "0.1.3"
 ntex-bytes = "0.1.8"
 ntex-tls = "0.1.0-b.2"
 ntex-io = "0.1.0-b.3"
-ntex-rt = { version = "0.4.0-b.0", default-features = false, features = ["tokio"] }
+ntex-rt = { version = "0.4.0-b.1", default-features = false, features = ["tokio"] }
 
 base64 = "0.13"
 bitflags = "1.3"