class RethinkDB::EMHandler

AsyncHandler that uses EventMachine to dispatch events

Public Instance Methods

handler() click to toggle source
# File lib/nobrainer_streams/rethinkdb_monkeypatch.rb, line 36
def handler
  callback
end
run() { || ... } click to toggle source
# File lib/nobrainer_streams/rethinkdb_monkeypatch.rb, line 26
def run
  if !EM.reactor_running?
    raise RuntimeError, "RethinkDB::RQL::em_run can only be called inside `EM.run`"
  end

  EM_Guard.register(connection)
  options[:query_handle_class] = EMQueryHandle
  yield
end