class ElasticAPM::Transport::Connection

def flush
  @mutex.synchronize do
    return unless @connected
    debug 'Closing request'
    @wr.close
    @conn_thread.join 5 if @conn_thread
  end
end