in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ProducerCacheEntry.java [68:73]
void releaseLease() {
int currentLeases = this.activeLeases.decrementAndGet();
if (currentLeases == 0 && this.removed) {
cleanupResources();
}
}