in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveProducerAdapter.java [106:113]
<R> Flux<R> usingProducerMany(BiFunction<Producer<T>, PublisherTransformer, Flux<R>> usingProducerAction) {
if (this.producerCache != null) {
return usingCachedProducerMany(usingProducerAction);
}
else {
return usingUncachedProducerMany(usingProducerAction);
}
}