Class LockedStreamImpl.CacheEntryFunction<K,V,R>

java.lang.Object

org.infinispan.stream.impl.LockedStreamImpl.CacheEntryFunction<K,V,R>

All Implemented Interfaces:

Function<CacheEntry<K,V>, Stream<KeyValuePair<K,R>>>

Enclosing class:

LockedStreamImpl<K,V>

@ProtoTypeId(1181)
public static class LockedStreamImpl.CacheEntryFunction<K,V,R>
extends Object
implements Function<CacheEntry<K,V>, Stream<KeyValuePair<K,R>>>

Since:

9.0

Author:

wburns

Field Summary

Fields

Modifier and Type	Field	Description
protected Cache<K,V>	cache
protected LockManager	lockManager
protected final Predicate<? super CacheEntry<K,V>>	predicate

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	CacheEntryFunction(BiFunction<Cache<K,V>, ? super CacheEntry<K,V>, R> biFunction, Predicate<? super CacheEntry<K,V>> predicate)

Method Summary

Modifier and Type	Method	Description
protected KeyValuePair<K,R>	actualPerform(Cache<K,V> cache, CacheEntry<K,V> entry)
Stream<KeyValuePair<K,R>>	apply(CacheEntry<K,V> kvCacheEntry)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Function

andThen, compose

Field Details

cache

protected transient Cache<K,V> cache

predicate

protected final Predicate<? super CacheEntry<K,V>> predicate

lockManager

protected transient volatile LockManager lockManager

Constructor Details

CacheEntryFunction

protected CacheEntryFunction(BiFunction<Cache<K,V>, ? super CacheEntry<K,V>, R> biFunction,
 Predicate<? super CacheEntry<K,V>> predicate)

Method Details

apply

public Stream<KeyValuePair<K,R>> apply(CacheEntry<K,V> kvCacheEntry)

Specified by:

apply in interface Function<K,V>

actualPerform

protected KeyValuePair<K,R> actualPerform(Cache<K,V> cache,
 CacheEntry<K,V> entry)