func checkAllStreamResponses()

in out_writeapi.go [244:251]

• 8 lines of code
• 2 McCabe index (conditional complexity)

func checkAllStreamResponses(ctx context.Context, streamSlice **[]*streamConfig, waitForResponse bool, currMutex *sync.Mutex, exactlyOnceConf bool, id int) {
	(*currMutex).Lock()
	defer (*currMutex).Unlock()
	sliceLen := len(**streamSlice)
	for i := 0; i < sliceLen; i++ {
		checkResponses(ctx, *streamSlice, waitForResponse, exactlyOnceConf, id, i)
	}
}