in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactiveProducerAdapter.java [79:86]
<R> Mono<R> usingProducer(BiFunction<Producer<T>, PublisherTransformer, Mono<R>> usingProducerAction) {
if (this.producerCache != null) {
return usingCachedProducer(usingProducerAction);
}
else {
return usingUncachedProducer(usingProducerAction);
}
}