Spring WebFlux WebClient：延迟执行

Question

当我像这样定义和调用客户机方法时：

webClient.get()
            .uri(endpoint)
            .headers(this::configureHttpHeaders)
            .retrieve()
            .bodyToMono(String.class)

关于更多上下文：在我的例子中，我只希望在CacheFlux onCacheMissResume被触发时执行它：

    Flux<T> defaulValue= client.getStringMono()
            .flatMapIterable(mapper::readObjects);

    CacheFlux.<String, T>lookup(key -> readFluxFromCache(cacheName, key), cacheKey)
                .onCacheMissResume(defaulValue)
                .andWriteWith((key, valueSignal) -> writeFluxToCache(cacheName, key, valueSignal))

Answer 1

我认为这与所谓的冷热出版商有关。

您可以在projectreactor.io/docs/core/release/reference/#reactor.hotcold中了解更多关于它们的信息。要将热发行者转换为冷发行者，可以使用defer函数。