func newLimiter()

in sg/internal/engine/limiter.go [15:23]


func newLimiter(concurrency int) channelLimiter {
	rv := make(chan struct{}, concurrency)

	for i := 0; i < concurrency; i++ {
		rv <- struct{}{}
	}

	return rv
}