Method WaitN

internal/engine/multi_limiter.go:19–32

(ctx context.Context, n int64)

}

func (m *MultiLimiter) WaitN(ctx context.Context, n int64) error {
	if m == nil {
		return nil
	}
	for i, l := range m.limiters {
		if err := l.WaitN(ctx, n); err != nil {
			for j := 0; j < i; j++ {
				m.limiters[j].Refund(n)
			}
			return err
		}
	}
	return nil
}