lib/deimos/consume/batch_consumption.rb in deimos-ruby-1.11.2 vs lib/deimos/consume/batch_consumption.rb in deimos-ruby-1.12.0

@@ -19,14 +19,14 @@
             end
           end
           metadata[:first_offset] = batch.first&.offset
 
           payloads = batch.map do |message|
-            message.payload ? self.class.decoder.decode(message.payload) : nil
+            decode_message(message.payload)
           end
           _received_batch(payloads, metadata)
           _with_span do
-            yield payloads, metadata
+            yield(payloads, metadata)
           end
         end
         _handle_batch_success(benchmark.real, payloads, metadata)
       rescue StandardError => e
         _handle_batch_error(e, payloads, metadata)