Uses of Interface
org.infinispan.util.function.SerializableFunction

Packages that use SerializableFunction

Package	Description
org.infinispan	This is the core of Infinispan, a distributed, transactional, highly scalable data grid platform.
org.infinispan.cache.impl
org.infinispan.functional	Functional API package
org.infinispan.manager	Cache manager API.
org.infinispan.query.impl	Query module internals.
org.infinispan.server.resp.json

Uses of SerializableFunction in org.infinispan

Methods in org.infinispan with parameters of type SerializableFunction

Modifier and Type	Method	Description
default V	AdvancedCache.computeIfAbsent(K key, SerializableFunction<? super K, ? extends V> mappingFunction, Metadata metadata)	Overloaded AdvancedCache.computeIfAbsent(Object, Function, Metadata) with SerializableFunction
default V	Cache.computeIfAbsent(K key, SerializableFunction<? super K, ? extends V> mappingFunction)	Overloaded Cache.computeIfAbsent(Object, Function) with Infinispan SerializableFunction.
default V	Cache.computeIfAbsent(K key, SerializableFunction<? super K, ? extends V> mappingFunction, long lifespan, TimeUnit lifespanUnit)	Overloaded BasicCache.computeIfAbsent(Object, Function, long, TimeUnit) with Infinispan SerializableFunction.
default V	Cache.computeIfAbsent(K key, SerializableFunction<? super K, ? extends V> mappingFunction, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)	Overloaded BasicCache.computeIfAbsent(Object, Function, long, TimeUnit, long, TimeUnit) with Infinispan SerializableFunction.
default CompletableFuture<V>	AdvancedCache.computeIfAbsentAsync(K key, SerializableFunction<? super K, ? extends V> mappingFunction, Metadata metadata)	Overloaded AdvancedCache.computeIfAbsentAsync(Object, Function, Metadata) with SerializableFunction
default CompletableFuture<V>	Cache.computeIfAbsentAsync(K key, SerializableFunction<? super K, ? extends V> mappingFunction)	Overloaded AsyncCache.computeIfAbsentAsync(Object, Function) with Infinispan SerializableFunction.
default CompletableFuture<V>	Cache.computeIfAbsentAsync(K key, SerializableFunction<? super K, ? extends V> mappingFunction, long lifespan, TimeUnit lifespanUnit)	Overloaded AsyncCache.computeIfAbsentAsync(Object, Function, long, TimeUnit) with Infinispan SerializableFunction.
default CompletableFuture<V>	Cache.computeIfAbsentAsync(K key, SerializableFunction<? super K, ? extends V> mappingFunction, long lifespan, TimeUnit lifespanUnit, long maxIdleTime, TimeUnit maxIdleTimeUnit)	Overloaded AsyncCache.computeIfAbsentAsync(Object, Function, long, TimeUnit, long, TimeUnit) with Infinispan SerializableFunction.
<R> SegmentPublisherSupplier<R>	CachePublisher.entryPublisher(SerializableFunction<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends org.reactivestreams.Publisher<R>> transformer)	Same as CachePublisher.entryPublisher(Function) except that the Function must also implement Serializable.
<R> CompletionStage<R>	CachePublisher.entryReduction(SerializableFunction<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends CompletionStage<R>> transformer, SerializableFunction<? super org.reactivestreams.Publisher<R>, ? extends CompletionStage<R>> finalizer)	Same as CachePublisher.entryReduction(Function, Function) except that the Functions must also implement Serializable.
default <R1> CacheStream<R1>	CacheStream.flatMap(SerializableFunction<? super R, ? extends Stream<? extends R1>> mapper)	Same as CacheStream.flatMap(Function) except that the Function must also implement Serializable
default DoubleCacheStream	CacheStream.flatMapToDouble(SerializableFunction<? super R, ? extends DoubleStream> mapper)	Same as CacheStream.flatMapToDouble(Function) except that the Function must also implement Serializable
default IntCacheStream	CacheStream.flatMapToInt(SerializableFunction<? super R, ? extends IntStream> mapper)	Same as CacheStream.flatMapToInt(Function) except that the Function must also implement Serializable
default LongCacheStream	CacheStream.flatMapToLong(SerializableFunction<? super R, ? extends LongStream> mapper)	Same as CacheStream.flatMapToLong(Function) except that the Function must also implement Serializable
<R> SegmentPublisherSupplier<R>	CachePublisher.keyPublisher(SerializableFunction<? super org.reactivestreams.Publisher<K>, ? extends org.reactivestreams.Publisher<R>> transformer)	Same as CachePublisher.keyPublisher(Function) except that the Function must also implement Serializable.
<R> CompletionStage<R>	CachePublisher.keyReduction(SerializableFunction<? super org.reactivestreams.Publisher<K>, ? extends CompletionStage<R>> transformer, SerializableFunction<? super org.reactivestreams.Publisher<R>, ? extends CompletionStage<R>> finalizer)	Same as CachePublisher.keyReduction(Function, Function) except that the Functions must also implement Serializable.
default <R1> CacheStream<R1>	CacheStream.map(SerializableFunction<? super R, ? extends R1> mapper)	Same as CacheStream.map(Function) except that the Function must also implement Serializable

Uses of SerializableFunction in org.infinispan.cache.impl

Methods in org.infinispan.cache.impl with parameters of type SerializableFunction

Modifier and Type	Method	Description
V	EncoderCache.computeIfAbsent(K key, SerializableFunction<? super K, ? extends V> mappingFunction, Metadata metadata)
CompletableFuture<V>	EncoderCache.computeIfAbsentAsync(K key, SerializableFunction<? super K, ? extends V> mappingFunction, Metadata metadata)
<R> SegmentPublisherSupplier<R>	CachePublisherImpl.entryPublisher(SerializableFunction<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends org.reactivestreams.Publisher<R>> transformer)
<R> CompletionStage<R>	CachePublisherImpl.entryReduction(SerializableFunction<? super org.reactivestreams.Publisher<CacheEntry<K,V>>, ? extends CompletionStage<R>> transformer, SerializableFunction<? super org.reactivestreams.Publisher<R>, ? extends CompletionStage<R>> finalizer)
<R> SegmentPublisherSupplier<R>	CachePublisherImpl.keyPublisher(SerializableFunction<? super org.reactivestreams.Publisher<K>, ? extends org.reactivestreams.Publisher<R>> transformer)
<R> CompletionStage<R>	CachePublisherImpl.keyReduction(SerializableFunction<? super org.reactivestreams.Publisher<K>, ? extends CompletionStage<R>> transformer, SerializableFunction<? super org.reactivestreams.Publisher<R>, ? extends CompletionStage<R>> finalizer)

Uses of SerializableFunction in org.infinispan.functional

Methods in org.infinispan.functional with parameters of type SerializableFunction

Modifier and Type	Method	Description
default <R> CompletableFuture<R>	FunctionalMap.ReadOnlyMap.eval(K key, SerializableFunction<EntryView.ReadEntryView<K,V>, R> f)	Same as FunctionalMap.ReadOnlyMap.eval(Object, Function) except that the function must also implement Serializable
default <R> CompletableFuture<R>	FunctionalMap.ReadWriteMap.eval(K key, SerializableFunction<EntryView.ReadWriteEntryView<K,V>, R> f)	Same as FunctionalMap.ReadWriteMap.eval(Object, Function) except that the function must also implement Serializable
default <R> Traversable<R>	FunctionalMap.ReadWriteMap.evalAll(SerializableFunction<EntryView.ReadWriteEntryView<K,V>, R> f)	Same as FunctionalMap.ReadWriteMap.evalAll(Function) except that the function must also implement Serializable
default <R> Traversable<R>	FunctionalMap.ReadOnlyMap.evalMany(Set<? extends K> keys, SerializableFunction<EntryView.ReadEntryView<K,V>, R> f)	Same as FunctionalMap.ReadOnlyMap.evalMany(Set, Function) except that the function must also implement Serializable
default <R> Traversable<R>	FunctionalMap.ReadWriteMap.evalMany(Set<? extends K> keys, SerializableFunction<EntryView.ReadWriteEntryView<K,V>, R> f)	Same as FunctionalMap.ReadWriteMap.evalMany(Set, Function) except that the function must also implement Serializable

Uses of SerializableFunction in org.infinispan.manager

Methods in org.infinispan.manager with parameters of type SerializableFunction

Modifier and Type	Method	Description
default <V> CompletableFuture<Void>	ClusterExecutor.submitConsumer(SerializableFunction<? super EmbeddedCacheManager, ? extends V> callable, TriConsumer<? super Address, ? super V, ? super Throwable> triConsumer)	The same as ClusterExecutor.submitConsumer(Function, TriConsumer), except the Callable must also implement Serializable.

Uses of SerializableFunction in org.infinispan.query.impl

Constructors in org.infinispan.query.impl with parameters of type SerializableFunction

Modifier	Constructor	Description
	QueryDefinition(String queryString, org.infinispan.objectfilter.impl.syntax.parser.IckleParsingResult.StatementType statementType, SerializableFunction<AdvancedCache<?,?>, org.infinispan.query.dsl.embedded.impl.QueryEngine<?>> queryEngineProvider, int originalMaxResults)

Uses of SerializableFunction in org.infinispan.server.resp.json

Classes in org.infinispan.server.resp.json that implement SerializableFunction

Modifier and Type	Class	Description
class	JsonArrayAppendFunction
class	JsonArrindexFunction
class	JsonArrinsertFunction
class	JsonArrpopFunction
class	JsonArrtrimFunction
class	JsonClearFunction
class	JsonDelFunction
class	JsonGetFunction
class	JsonLenArrayFunction
class	JsonLenFunction
class	JsonLenObjFunction
class	JsonLenStrFunction
class	JsonMergeFunction
class	JsonNumIncrOpFunction
class	JsonNumMultOpFunction
class	JsonNumOpFunction
class	JsonObjkeysFunction
class	JsonRespFunction
class	JsonSetFunction
class	JsonStringAppendFunction
class	JsonToggleFunction
class	JsonTypeFunction