in pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ReactivePulsarResourceAdapter.java [34:46]
private static <T> Supplier<T> cachedSupplier(Supplier<T> supplier) {
return new Supplier<T>() {
T cachedValue;
@Override
public synchronized T get() {
if (this.cachedValue == null) {
this.cachedValue = supplier.get();
}
return this.cachedValue;
}
};
}