reactor.cache

Interface CacheFlux.FluxCacheBuilderMapMiss<VALUE>

Type Parameters:

VALUE - type

Enclosing class:

CacheFlux

public static interface CacheFlux.FluxCacheBuilderMapMiss<VALUE>

Setup original source to fallback to in case of cache miss and return a wrapped Flux that transparently looks up data from a Map representation of a cache and store data into the cache in case of cache miss.

Method Summary

Modifier and Type	Method and Description
default reactor.core.publisher.Flux<VALUE>	onCacheMissResume(reactor.core.publisher.Flux<VALUE> other) Setup original source to fallback to in case of cache miss.
reactor.core.publisher.Flux<VALUE>	onCacheMissResume(Supplier<reactor.core.publisher.Flux<VALUE>> otherSupplier) Setup original source to fallback to in case of cache miss, through a Supplier which allows lazy resolution of the source.

Method Detail

onCacheMissResume

default reactor.core.publisher.Flux<VALUE> onCacheMissResume(reactor.core.publisher.Flux<VALUE> other)

Setup original source to fallback to in case of cache miss.

Parameters:

other - original source

Returns:

A wrapped Flux that transparently looks up data from a cache and store data into the cache.

onCacheMissResume

reactor.core.publisher.Flux<VALUE> onCacheMissResume(Supplier<reactor.core.publisher.Flux<VALUE>> otherSupplier)

Setup original source to fallback to in case of cache miss, through a Supplier which allows lazy resolution of the source.

Parameters:

otherSupplier - original source Supplier

Returns:

A wrapped Flux that transparently looks up data from a cache and store data into the cache.