class PollApi

Public Class Methods

new(client) click to toggle source
# File lib/linerb/api/pollApi.rb, line 6
def initialize(client)
  @client = client
end

Public Instance Methods

api_fetch_operations() click to toggle source
# File lib/linerb/api/pollApi.rb, line 10
def api_fetch_operations
  recv = PollRecv.new

  rev = @client.getLastOpRevision()

  @local_rev = rev

  last_rev = rev

  while true do
    begin
      operations = @client.fetchOperations(@local_rev, 50)

      operations.each { |op|

        if op::type == P0_a_e_a_b_od::END_OF_OPERATION || op::type == P0_a_e_a_b_od::DUMMY
          next
        end

        @local_rev = op::revision

        if last_rev < op::revision
          last_rev = op::revision
          Async do
            recv.op_process(op)
          end
        end
      }

    rescue Net::ReadTimeout
      retry
    end
  end
end