remove excess write and rewind in exchange

cloudamqp · Dec 18, 2024 · a766b9b · a766b9b
1 parent 969b194
commit a766b9b
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 5 deletions.
diff --git a/src/lavinmq/mqtt/exchange.cr b/src/lavinmq/mqtt/exchange.cr
@@ -50,10 +50,7 @@ module LavinMQ
 
         timestamp = RoughTime.unix_ms
         bodysize = packet.payload.size.to_u64
-        body = ::IO::Memory.new(bodysize)
-        body.write(packet.payload)
-        body.rewind
-
+        body = ::IO::Memory.new(packet.payload, false)
         if packet.retain?
           @retain_store.retain(packet.topic, body, bodysize)
           body.rewind

diff --git a/src/lavinmq/mqtt/session.cr b/src/lavinmq/mqtt/session.cr
@@ -145,7 +145,6 @@ module LavinMQ
       def build_packet(env, packet_id) : MQTT::Publish
         msg = env.message
         retained = msg.properties.try &.headers.try &.["mqtt.retain"]? == true
-
         qos = msg.properties.delivery_mode || 0u8
         qos = 1u8 if qos > 1
         MQTT::Publish.new(