Fix clippy errors in nats client

Signed-off-by: Tomasz Pietrek <[email protected]>
nats-io · Aug 31, 2023 · 76e2a02 · 76e2a02
1 parent a9b6534
commit 76e2a02
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/nats/src/jetstream/push_subscription.rs b/nats/src/jetstream/push_subscription.rs
@@ -342,7 +342,7 @@ impl PushSubscription {
                 self.0.stream, self.0.consumer,
             ))
             .spawn(move || {
-                for m in sub.iter() {
+                for m in &sub {
                     if let Err(e) = handler(m) {
                         // TODO(dlc) - Capture for last error?
                         log::error!("Error in callback! {:?}", e);
@@ -394,7 +394,7 @@ impl PushSubscription {
                 self.0.consumer, self.0.stream
             ))
             .spawn(move || {
-                for message in sub.iter() {
+                for message in &sub {
                     if let Err(err) = handler(&message) {
                         log::error!("Error in callback! {:?}", err);
                     }

diff --git a/nats/src/subscription.rs b/nats/src/subscription.rs
@@ -246,7 +246,7 @@ impl Subscription {
         thread::Builder::new()
             .name(format!("nats_subscriber_{}_{}", self.0.sid, self.0.subject))
             .spawn(move || {
-                for m in sub.iter() {
+                for m in &sub {
                     if let Err(e) = handler(m) {
                         // TODO(dlc) - Capture for last error?
                         log::error!("Error in callback! {:?}", e);