rubocop fixes

cloudamqp · Mar 24, 2024 · f444e19 · f444e19
1 parent 71529fc
commit f444e19
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/lib/amqp/client/channel.rb b/lib/amqp/client/channel.rb
@@ -411,6 +411,7 @@ def wait_for_confirms
 
           ok = @unconfirmed_empty.pop
           raise Error::Closed.new(@id, *@closed) if ok.nil?
+
           ok
         end
 
@@ -431,7 +432,11 @@ def confirm(args)
 
           ok = ack_or_nack == :ack
           @unconfirmed_empty.push(ok) until @unconfirmed_empty.num_waiting.zero?
-          @unconfirmed_empty.pop if @unconfirmed_empty.length > 0 # don't leave a residual ok in the queue
+          begin
+            @unconfirmed_empty.pop(true) # don't leave a residual ok in the queue
+          rescue ThreadError
+            nil
+          end
         end
 
         # @!endgroup