Class: NoBrainer::Streams::ConcurrentAsyncHandler

Inherits:
RethinkDB::AsyncHandler show all
Defined in:
lib/nobrainer_streams.rb

Defined Under Namespace

Classes: AsyncQueryHandler

Instance Attribute Summary

Attributes inherited from RethinkDB::AsyncHandler

#callback, #connection, #options

Instance Method Summary collapse

Instance Method Details

#handler ⇒ Object 



62
63
64
 
# File 'lib/nobrainer_streams.rb', line 62

def handler
  callback
end

#run(&action) ⇒ Object 



57
58
59
60
 
# File 'lib/nobrainer_streams.rb', line 57

def run(&action)
  options[:query_handle_class] = AsyncQueryHandler
  yield
end