class ElasticAPM::Transport::Connection

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