class RegistryApiClient::PubSub
It's same as waiter but support multiple subscribers
Public Class Methods
new()
click to toggle source
# File lib/docker_cake/registry_api_client.rb, line 57 def initialize @waiters = [] end
Public Instance Methods
notify(value)
click to toggle source
# File lib/docker_cake/registry_api_client.rb, line 67 def notify(value) while waiter = @waiters.shift waiter.notify(value) end end
wait()
click to toggle source
# File lib/docker_cake/registry_api_client.rb, line 61 def wait waiter = Waiter.new @waiters << waiter waiter.wait end