class Droonga::Client::Connection::DroongaProtocol::Coolio::InfiniteRequest
Attributes
on_timeout[W]
Public Class Methods
new(loop, options={})
click to toggle source
# File lib/droonga/client/connection/droonga-protocol/coolio.rb, line 53 def initialize(loop, options={}) @loop = loop @subscription_timeout = options[:subscription_timeout] end
Public Instance Methods
wait()
click to toggle source
# File lib/droonga/client/connection/droonga-protocol/coolio.rb, line 58 def wait if @subscription_timeout @timer = Coolio::TimerWatcher.new(@subscription_timeout) @timer.on_timer do @timer.detach @on_timeout.call if @on_timeout end @loop.attach(@timer) end @loop.run end