class RethinkDB::EMQueryHandle

Public Instance Methods

callback(res) click to toggle source
Calls superclass method RethinkDB::QueryHandle#callback
# File lib/nobrainer_streams/rethinkdb_monkeypatch.rb, line 153
def callback(res)
  if !EM.reactor_running?
      @closed = true
      @conn.stop(@token)
      return
  end
  super(res)
end
guarded_async_run(&b) click to toggle source
# File lib/nobrainer_streams/rethinkdb_monkeypatch.rb, line 147
def guarded_async_run(&b)
  EM.next_tick {
    b.call if !@closed
  }
end