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