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