void scheduleSubscribed()

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

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

	void scheduleSubscribed(InflightLimiterSubscriber<?> subscriber) {
		if (!this.triggerNextWorker.isDisposed()) {
			this.triggerNextWorker.schedule(() -> {
				if (!subscriber.isDisposed()) {
					subscriber.requestMore();
				}
			});
		}
	}