Function NewBlocking

gate/gate.go:147–151

(maxConcurrent int)

}

func NewBlocking(maxConcurrent int) Gate {
	return &blockingGate{
		ch: make(chan struct{}, maxConcurrent),
	}
}

type blockingGate struct {
	ch chan struct{}