public void request()

in pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/InflightLimiter.java [203:212]

• 10 lines of code
• 3 McCabe index (conditional complexity)

			public void request(long n) {
				if (n == Long.MAX_VALUE) {
					InflightLimiterSubscriber.this.requestedDemand.set(n);
				}
				else if (InflightLimiterSubscriber.this.requestedDemand.get() != Long.MAX_VALUE) {
					InflightLimiterSubscriber.this.requestedDemand.addAndGet(n);
				}
				maybeAddToPending();
				maybeTriggerNext();
			}