Class: NoBrainer::Streams::ConcurrentAsyncHandler

Inherits:

RethinkDB::AsyncHandler

• Object
• RethinkDB::AsyncHandler
• NoBrainer::Streams::ConcurrentAsyncHandler

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

• #handler ⇒ Object
• #run(&action) ⇒ Object

Instance Method Details

#handler ⇒ Object

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

def handler
  callback
end

#run(&action) ⇒ Object

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

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