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