class SplitIoClient::SSE::Workers::SegmentsWorker

def perform
  while (item = @queue.pop)
    segment_name = item[:segment_name]
    cn = item[:change_number]
    @config.logger.debug("SegmentsWorker change_number dequeue #{segment_name}, #{cn}")
    @synchronizer.fetch_segment(segment_name, cn)
  end
end