Class: RethinkDB::EMQueryHandle

Inherits:
QueryHandle show all
Defined in:
lib/nobrainer_streams/rethinkdb_monkeypatch.rb

Instance Method Summary collapse

Instance Method Details

#callback(res) ⇒ Object 



153
154
155
156
157
158
159
160
 
# 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) ⇒ Object 



147
148
149
150
151
 
# File 'lib/nobrainer_streams/rethinkdb_monkeypatch.rb', line 147

def guarded_async_run(&b)
  EM.next_tick {
    b.call if !@closed
  }
end