lib/google/cloud/pubsub/subscriber/inventory.rb in google-cloud-pubsub-0.36.0 vs lib/google/cloud/pubsub/subscriber/inventory.rb in google-cloud-pubsub-0.37.0

- old
+ new

@@ -38,20 +38,22 @@ def ack_ids @_ack_ids end def add *ack_ids - ack_ids.flatten!.compact! + ack_ids.flatten! + ack_ids.compact! return if ack_ids.empty? synchronize do @_ack_ids += ack_ids @wait_cond.broadcast end end def remove *ack_ids - ack_ids.flatten!.compact! + ack_ids.flatten! + ack_ids.compact! return if ack_ids.empty? synchronize do @_ack_ids -= ack_ids @wait_cond.broadcast