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