(e lfshttp.Endpoint)
| 955 | } |
| 956 | |
| 957 | func (q *TransferQueue) toAdapterCfg(e lfshttp.Endpoint) AdapterConfig { |
| 958 | apiClient := q.manifest.APIClient() |
| 959 | concurrency := q.manifest.ConcurrentTransfers() |
| 960 | |
| 961 | return &adapterConfig{ |
| 962 | concurrentTransfers: concurrency, |
| 963 | apiClient: apiClient, |
| 964 | remote: q.remote, |
| 965 | } |
| 966 | } |
| 967 | |
| 968 | // Wait waits for the queue to finish processing all transfers. Once Wait is |
| 969 | // called, Add will no longer add transfers to the queue. Any failed |
no test coverage detected