protected void hookOnSubscribe()

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

• 6 lines of code
• 2 McCabe index (conditional complexity)

		protected void hookOnSubscribe(Subscription subscription) {
			if (this.state.compareAndSet(InflightLimiterSubscriberState.SUBSCRIBING,
					InflightLimiterSubscriberState.SUBSCRIBED)) {
				scheduleSubscribed(this);
			}
		}