(ctx context.Context, f *sendReceiveFolder, pullChan chan<- pullBlockState, finisherChan chan<- *sharedPullerState)
| 1321 | } |
| 1322 | |
| 1323 | func startCopier(ctx context.Context, f *sendReceiveFolder, pullChan chan<- pullBlockState, finisherChan chan<- *sharedPullerState) (chan copyBlocksState, *sync.WaitGroup) { |
| 1324 | copyChan := make(chan copyBlocksState) |
| 1325 | wg := new(sync.WaitGroup) |
| 1326 | wg.Go(func() { |
| 1327 | f.copierRoutine(ctx, copyChan, pullChan, finisherChan) |
| 1328 | }) |
| 1329 | return copyChan, wg |
| 1330 | } |
no test coverage detected