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