Class: Combi::ResponseStore

Inherits:
Object
  • Object
show all
Defined in:
lib/combi/response_store.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ ResponseStore

Returns a new instance of ResponseStore.



5
6
7
 
# File 'lib/combi/response_store.rb', line 5

def initialize()
  @waiters = {}
end

Instance Method Details

#add_waiter(key, waiter) ⇒ Object 



9
10
11
12
13
 
# File 'lib/combi/response_store.rb', line 9

def add_waiter(key, waiter)
  @waiters[key] = waiter
  waiter.callback { |r| finish key }
  waiter.errback  { |r| finish key }
end

#finish(key) ⇒ Object 



27
28
29
 
# File 'lib/combi/response_store.rb', line 27

def finish(key)
  @waiters.delete key
end

#handle_rpc_response(response) ⇒ Object 



15
16
17
18
19
20
21
22
23
24
25
 
# File 'lib/combi/response_store.rb', line 15

def handle_rpc_response(response)
  correlation_id = response['correlation_id']
  waiter = @waiters[correlation_id]
  return unless waiter
  response = JSON.parse response['response']
  if response.respond_to?(:keys) and response['error']
    waiter.fail(response)
  else
    waiter.succeed(response)
  end
end