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.



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

def initialize()
  @waiters = {}
end

Instance Method Details

#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 = response[:response] #Yajl::Parser.parse response[:response], sybolize_keys: true
  if response.respond_to?(:keys) and response[:error]
    waiter.fail response
  else
    waiter.succeed response
  end
end

#wait_for(correlation_id, timeout) ⇒ Object

Returns an EM::Deferrable



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

def wait_for(correlation_id, timeout)
  waiter = EM::DefaultDeferrable.new
  add_waiter correlation_id, waiter
  waiter.timeout timeout, error: 'Timeout::Error'
end