func WithValidateThrottle(n int) Option {
	return func(ps *PubSub) error {
		ps.validateThrottle = make(chan struct{}, n)
		return nil
	}
}
func WithValidateThrottle(n int) Option {
	return func(ps *PubSub) error {
		ps.validateThrottle = make(chan struct{}, n)
		return nil
	}
}
func WithValidateThrottle ( n int ) Option { return func ( ps * PubSub ) error { ps . validateThrottle = make ( chan struct { } , n ) return nil } }
// WithValidateThrottle sets the upper bound on the number of active validation
// goroutines.
WithValidateThrottle sets the upper bound on the number of active validation goroutines .