class SplitIoClient::Cache::Senders::EventsSender

def call          
  events_thread
end

def events_thread
  @config.threads[:events_sender] = Thread.new do
    begin
      @config.logger.info('Starting events service')
      loop do
        post_events
        sleep(SplitIoClient::Utilities.randomize_interval(@config.events_push_rate))
      end
    rescue SplitIoClient::SDKShutdownException
      post_events
      @config.logger.info('Posting events due to shutdown')
    end
  end
end

def initialize(events_repository, config)
  @events_repository = events_repository
  @config = config
end

def post_events
  @events_repository.post_events
end