minor udpate / making create_client public at crate level

rabbitmq · Nov 24, 2024 · 897e9be · 897e9be
1 parent 90364ff
commit 897e9be
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 8 deletions.
diff --git a/src/consumer.rs b/src/consumer.rs
@@ -132,13 +132,11 @@ impl ConsumerBuilder {
 
         let collector = self.environment.options.client_options.collector.clone();
 
-        let client_uwrapped = self
+        let client = self
             .environment
             .create_consumer_client(stream, self.client_provided_name.clone())
             .await?;
 
-        let client = client_uwrapped.clone();
-
         let subscription_id = 1;
         let (tx, rx) = channel(10000);
         let consumer = Arc::new(ConsumerInternal {

diff --git a/src/environment.rs b/src/environment.rs
@@ -39,7 +39,7 @@ impl Environment {
         Ok(Environment { options })
     }
 
-    pub async fn create_producer_client(
+    pub(crate) async fn create_producer_client(
         self,
         stream: &str,
         client_provided_name: String,
@@ -91,7 +91,7 @@ impl Environment {
         Ok(client)
     }
 
-    pub async fn create_consumer_client(
+    pub(crate) async fn create_consumer_client(
         self,
         stream: &str,
         client_provided_name: String,

diff --git a/src/producer.rs b/src/producer.rs
@@ -120,13 +120,11 @@ impl<T> ProducerBuilder<T> {
 
         let metrics_collector = self.environment.options.client_options.collector.clone();
 
-        let client_unwrapped = self
+        let client = self
             .environment
             .create_producer_client(stream, self.client_provided_name.clone())
             .await?;
 
-        let client = client_unwrapped;
-
         let mut publish_version = 1;
 
         if self.filter_value_extractor.is_some() {