Method: NoBrainer::QueryRunner::EMDriver::ResponseHandler#on_close

Defined in:
lib/no_brainer/query_runner/em_driver.rb

#on_close(caller) ⇒ Object 



45
46
47
48
49
 
# File 'lib/no_brainer/query_runner/em_driver.rb', line 45

def on_close(caller)
  return if @has_atom
  return on_error(RethinkDB::RqlRuntimeError.new("NoBrainer EM driver: No data received"), caller) unless @has_data
  @queue ? push(:close) : set_atom([])
end