func()

in loader/stream_loader.go [380:383]

• 4 lines of code
• 1 McCabe index (conditional complexity)

func (s *StreamLoad) ExecuteGetAndSend(maxRowsPerTask int, maxBytesPerTask int, workerIndex int) {
	s.wg.Add(1)
	go s.executeGetAndSend(maxRowsPerTask, maxBytesPerTask, workerIndex)
}