Fix "delcare_ok" typo

gftea · Sep 18, 2023 · e1c3856 · e1c3856
1 parent 0a9c635
commit e1c3856
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/amqprs/src/api/channel/queue.rs b/amqprs/src/api/channel/queue.rs
@@ -389,17 +389,17 @@ impl Channel {
             Ok(None)
         } else {
             let responder_rx = self.register_responder(DeclareQueueOk::header()).await?;
-            let delcare_ok = synchronous_request!(
+            let declare_ok = synchronous_request!(
                 self.shared.outgoing_tx,
                 (self.channel_id(), declare.into_frame()),
                 responder_rx,
                 Frame::DeclareQueueOk,
                 Error::ChannelUseError
             )?;
             Ok(Some((
-                delcare_ok.queue.into(),
-                delcare_ok.message_count,
-                delcare_ok.consumer_count,
+                declare_ok.queue.into(),
+                declare_ok.message_count,
+                declare_ok.consumer_count,
             )))
         }
     }