From c4809afbba4a267def25c99de7780f071f5493f0 Mon Sep 17 00:00:00 2001
From: Jarema <melgaer@gmail.com>
Date: Sun, 1 May 2022 21:08:09 +0200
Subject: [PATCH] Make Options builder consuming

---
 async-nats/src/options.rs | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/async-nats/src/options.rs b/async-nats/src/options.rs
index f61e56823..4323e12a6 100644
--- a/async-nats/src/options.rs
+++ b/async-nats/src/options.rs
@@ -134,7 +134,7 @@ impl ConnectOptions {
     /// # Ok(())
     /// # }
     /// ```
-    pub fn add_root_certificates(&mut self, path: PathBuf) -> &mut ConnectOptions {
+    pub fn add_root_certificates(mut self, path: PathBuf) -> ConnectOptions {
         self.certificates = vec![path];
         self
     }
@@ -150,7 +150,7 @@ impl ConnectOptions {
     /// # Ok(())
     /// # }
     /// ```
-    pub fn add_client_certificate(&mut self, cert: PathBuf, key: PathBuf) -> &mut ConnectOptions {
+    pub fn add_client_certificate(mut self, cert: PathBuf, key: PathBuf) -> ConnectOptions {
         self.client_cert = Some(cert);
         self.client_key = Some(key);
         self
@@ -167,7 +167,7 @@ impl ConnectOptions {
     /// # Ok(())
     /// # }
     /// ```
-    pub fn require_tls<'a>(&'a mut self, is_required: bool) -> &'a mut ConnectOptions {
+    pub fn require_tls(mut self, is_required: bool) -> ConnectOptions {
         self.tls_required = is_required;
         self
     }
@@ -185,7 +185,7 @@ impl ConnectOptions {
     /// # Ok(())
     /// # }
     /// ```
-    pub fn flush_interval(&mut self, flush_interval: Duration) -> &mut ConnectOptions {
+    pub fn flush_interval(mut self, flush_interval: Duration) -> ConnectOptions {
         self.flush_interval = flush_interval;
         self
     }
@@ -201,12 +201,12 @@ impl ConnectOptions {
     /// # Ok(())
     /// # }
     /// ```
-    pub fn ping_interval(&mut self, ping_interval: Duration) -> &mut ConnectOptions {
+    pub fn ping_interval(mut self, ping_interval: Duration) -> ConnectOptions {
         self.ping_interval = ping_interval;
         self
     }
 
-    pub fn error_callback<F>(&mut self, cb: F) -> &mut ConnectOptions
+    pub fn error_callback<F>(mut self, cb: F) -> ConnectOptions
     where
         F: Fn(ServerError) -> BoxFuture<'static, ()> + Send + Sync + 'static,
     {
@@ -214,7 +214,7 @@ impl ConnectOptions {
         self
     }
 
-    pub fn reconnect_callback<F>(&mut self, cb: F) -> &mut ConnectOptions
+    pub fn reconnect_callback<F>(mut self, cb: F) -> ConnectOptions
     where
         F: Fn() -> BoxFuture<'static, ()> + Send + Sync + 'static,
     {
@@ -222,7 +222,7 @@ impl ConnectOptions {
         self
     }
 
-    pub fn disconnect_callback<F>(&mut self, cb: F) -> &mut ConnectOptions
+    pub fn disconnect_callback<F>(mut self, cb: F) -> ConnectOptions
     where
         F: Fn() -> BoxFuture<'static, ()> + Send + Sync + 'static,
     {