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