Method: NoBrainer::QueryRunner::EMDriver::ResponseHandler#push

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

#push(v) ⇒ Object 



72
73
74
75
76
77
 
# File 'lib/no_brainer/query_runner/em_driver.rb', line 72

def push(v)
  raise "internal error: unexpected stream" if @has_atom
  @queue ||= EventMachine::Queue.new
  @queue.push(v)
  response_ready!
end