Class: RegistryApiClient::PubSub

Inherits:
Object
  • Object
show all
Defined in:
lib/docker_cake/registry_api_client.rb

Overview

It’s same as waiter but support multiple subscribers

Instance Method Summary collapse

Constructor Details

#initialize ⇒ PubSub

Returns a new instance of PubSub.



47
48
49
 
# File 'lib/docker_cake/registry_api_client.rb', line 47

def initialize
  @waiters = []
end

Instance Method Details

#notify(value) ⇒ Object 



57
58
59
60
61
 
# File 'lib/docker_cake/registry_api_client.rb', line 57

def notify(value)
  while waiter = @waiters.shift
    waiter.notify(value)
  end
end

#wait ⇒ Object 



51
52
53
54
55
 
# File 'lib/docker_cake/registry_api_client.rb', line 51

def wait
  waiter = Waiter.new
  @waiters << waiter
  waiter.wait
end