class NoBrainer::Streams::ConcurrentAsyncHandler

Public Instance Methods

handler() click to toggle source
# File lib/nobrainer_streams.rb, line 71
def handler
  callback
end
run() { || ... } click to toggle source
# File lib/nobrainer_streams.rb, line 66
def run(&action)
  options[:query_handle_class] = AsyncQueryHandler
  yield
end