public Publisher transform()

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

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

	public <T> Publisher<T> transform(Publisher<T> publisher) {
		if (publisher instanceof Mono<?>) {
			return createOperator((Mono<T>) publisher);
		}
		else {
			return createOperator(Flux.from(publisher));
		}
	}