Clippy fixes

bschwind · Nov 26, 2020 · f574fde · f574fde
1 parent d039c9f
commit f574fde
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/mqtt-v5-broker/src/broker.rs b/mqtt-v5-broker/src/broker.rs
@@ -168,7 +168,7 @@ pub enum WillDisconnectLogic {
 #[derive(Debug)]
 pub enum BrokerMessage {
     NewClient(Box<ConnectPacket>, Sender<ClientMessage>),
-    Publish(String, PublishPacket),
+    Publish(String, Box<PublishPacket>),
     PublishAck(String, PublishAckPacket), // TODO - This can be handled by the client task
     PublishRelease(String, PublishReleasePacket), // TODO - This can be handled by the client task
     PublishReceived(String, PublishReceivedPacket),
@@ -662,7 +662,7 @@ impl Broker {
                     self.handle_disconnect(client_id, will_disconnect_logic);
                 },
                 BrokerMessage::Publish(client_id, packet) => {
-                    self.handle_publish(client_id, packet);
+                    self.handle_publish(client_id, *packet);
                 },
                 BrokerMessage::PublishAck(client_id, packet) => {
                     self.handle_publish_ack(client_id, packet);

diff --git a/mqtt-v5-broker/src/client.rs b/mqtt-v5-broker/src/client.rs
@@ -191,7 +191,7 @@ impl<ST: Stream<Item = PacketResult> + Unpin, SI: Sink<Packet, Error = EncodeErr
                             }
 
                             broker_tx
-                                .send(BrokerMessage::Publish(client_id.clone(), packet))
+                                .send(BrokerMessage::Publish(client_id.clone(), Box::new(packet)))
                                 .await
                                 .expect("Couldn't send Publish message to broker");
                         },