Merge pull request #177 from erebe/master

Add async request_timeout

CHANGELOG.md

@@ -1,3 +1,9 @@
+# 0.9.15
+
+## Improvements
+
+- #177 Add support of request_timeout for async-nats
+
 # 0.9.14
 
 ## New Features

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "nats"
-version = "0.9.14"
+version = "0.9.15"
 description = "A Rust NATS client"
 authors = ["Derek Collison <[email protected]>", "Tyler Neely <[email protected]>", "Stjepan Glavina <[email protected]>"]
 edition = "2018"

async-nats/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "async-nats"
-version = "0.9.14"
+version = "0.9.15"
 description = "An async Rust NATS client"
 authors = ["Derek Collison <[email protected]>", "Tyler Neely <[email protected]>", "Stjepan Glavina <[email protected]>"]
 edition = "2018"
@@ -17,7 +17,7 @@ maintenance = { status = "actively-developed" }
 
 [dependencies]
 blocking = "1.0.2"
-nats = { path = "..", version = "0.9.14" }
+nats = { path = "..", version = "0.9.15" }
 
 [dev-dependencies]
 smol = "1.2.5"

async-nats/src/lib.rs

@@ -160,6 +160,21 @@ impl Connection {
         Ok(Message::new(msg))
     }
 
+    /// Publishes a message and waits for the response or until the
+    /// timeout duration is reached
+    pub async fn request_timeout(
+        &self,
+        subject: &str,
+        msg: impl AsRef<[u8]>,
+        timeout: Duration,
+    ) -> io::Result<Message> {
+        let subject = subject.to_string();
+        let msg = msg.as_ref().to_vec();
+        let inner = self.inner.clone();
+        let msg = unblock(move || inner.request_timeout(&subject, msg, timeout)).await?;
+        Ok(Message::new(msg))
+    }
+
     /// Publishes a message and returns a subscription for awaiting the
     /// response.
     pub async fn request_multi(