Fix clippy warnings

Signed-off-by: Tomasz Pietrek <[email protected]>

async-nats/src/client.rs

@@ -344,7 +344,7 @@ impl Client {
         if let Some(inbox) = request.inbox {
             let timeout = request.timeout.unwrap_or(self.request_timeout);
             let mut subscriber = self.subscribe(inbox.clone().into()).await?;
-            let payload: Bytes = request.payload.unwrap_or_else(Bytes::new);
+            let payload: Bytes = request.payload.unwrap_or_default();
             match request.headers {
                 Some(headers) => {
                     self.publish_with_reply_and_headers(subject, inbox.into(), headers, payload)
@@ -381,7 +381,7 @@ impl Client {
         } else {
             let (sender, receiver) = oneshot::channel();
 
-            let payload = request.payload.unwrap_or_else(Bytes::new);
+            let payload = request.payload.unwrap_or_default();
             let respond = self.new_inbox().into();
             let headers = request.headers;
 

async-nats/src/jetstream/consumer/pull.rs

@@ -854,7 +854,6 @@ impl Stream {
             let batch = batch_config;
             let consumer = consumer.clone();
             let mut context = consumer.context.clone();
-            let subject = subject;
             let inbox = inbox.clone();
             async move {
                 loop {

nats/nats_test_server/src/lib.rs

@@ -436,10 +436,7 @@ impl Client {
                 let subject = parts.next().unwrap();
                 let sid = parts.next().unwrap();
                 assert_eq!(parts.next(), None);
-                let entry = self
-                    .subs
-                    .entry(subject.to_string())
-                    .or_insert_with(HashSet::new);
+                let entry = self.subs.entry(subject.to_string()).or_default();
                 entry.insert(sid.to_string());
                 ClientAction::None
             }