reactor.cache

Interface CacheFlux.FluxCacheBuilderCacheWriter<KEY,VALUE>

Type Parameters:

KEY - Key type

VALUE - Value type

Enclosing class:

CacheFlux

public static interface CacheFlux.FluxCacheBuilderCacheWriter<KEY,VALUE>

Set up the cache writer BiFunction to use to store the source data into the cache in case of cache miss. The source Flux is materialized into a List of Signal (completion/error signals included) to be stored.

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<VALUE>	andWriteWith(BiFunction<KEY,List<reactor.core.publisher.Signal<VALUE>>,reactor.core.publisher.Mono<Void>> writer) Set up the cache writer BiFunction to use to store the source data into the cache in case of cache miss.

Method Detail

andWriteWith

reactor.core.publisher.Flux<VALUE> andWriteWith(BiFunction<KEY,List<reactor.core.publisher.Signal<VALUE>>,reactor.core.publisher.Mono<Void>> writer)

Set up the cache writer BiFunction to use to store the source data into the cache in case of cache miss. The source Flux is materialized into a List of Signal (completion/error signals included) to be stored.

Parameters:

writer - BiFunction of key-signals to Mono<Void> (which represents the completion of the cache write operation.

Returns:

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