code: func (q *TransferQueue) run() {
  	tracerx.Printf("tq: running as batched queue, batch size of %d", q.batchSize)
  
  	go q.errorCollector()
  	go q.collectBatches()
  }
docs: // run begins the transfer queue. It transfers files sequentially or
  // concurrently depending on the Config.ConcurrentTransfers() value.