lib/google/cloud/pubsub/subscriber/inventory.rb in google-cloud-pubsub-1.0.0 vs lib/google/cloud/pubsub/subscriber/inventory.rb in google-cloud-pubsub-1.0.1
- old
+ new
@@ -112,12 +112,12 @@
delay_target ||= calc_target
delay_gap = delay_target - Time.now
unless delay_gap.positive?
- delay_target = nil
- delay_gap = nil # wait until broadcast
+ delay_target = calc_target
stream.renew_lease!
+ next
end
@wait_cond.wait delay_gap
end
end