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