refactor(limiter): make blocking/non-blocking code more similar

exaring · Oct 12, 2023 · 78e4bfe · 78e4bfe
1 parent 1c60646
commit 78e4bfe
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/limiter.go b/limiter.go
@@ -30,10 +30,9 @@ func newLimiter(origFactory observerFactory, limit int64, block bool) observerFa
 		}
 	}
 	return func(ctx context.Context) (observer, error) {
-		if sem.TryAcquire(1) {
-			return wrappedFactory(ctx)
-		} else {
+		if !sem.TryAcquire(1) {
 			return nil, ErrConcurrencyLimitReached
 		}
+		return wrappedFactory(ctx)
 	}
 }