class SplitIoClient::SSE::Workers::SplitsWorker

def perform
  while (notification = @queue.pop)
    @config.logger.debug("feature_flags_worker change_number dequeue #{notification.data['changeNumber']}")
    case notification.data['type']
    when SSE::EventSource::EventTypes::SPLIT_UPDATE
      success = update_feature_flag(notification)
      @synchronizer.fetch_splits(notification.data['changeNumber']) unless success
    when SSE::EventSource::EventTypes::SPLIT_KILL
      kill_feature_flag(notification)
    end
  end
end