class ElasticAPM::Transport::Connection

def schedule_closing
  @close_task =
    Concurrent::ScheduledTask.execute(@config.api_request_time) do
      flush
    end
end