Class: NoBrainer::Streams::ConcurrentAsyncHandler::AsyncQueryHandler

Inherits:

RethinkDB::QueryHandle

• Object
• RethinkDB::QueryHandle
• NoBrainer::Streams::ConcurrentAsyncHandler::AsyncQueryHandler

Defined in:

lib/nobrainer_streams.rb

Instance Method Summary

• #guarded_async_run(&b) ⇒ Object

Methods inherited from RethinkDB::QueryHandle

#callback

Instance Method Details

#guarded_async_run(&b) ⇒ Object

# File 'lib/nobrainer_streams.rb', line 76

def guarded_async_run(&b)
  Concurrent.global_io_executor.post(&b)
end