Class LockedStreamImpl.CacheEntryConsumer<K,V>

java.lang.Object

org.infinispan.stream.impl.LockedStreamImpl.CacheEntryConsumer<K,V>

All Implemented Interfaces:

BiConsumer<Cache<K,V>, CacheEntry<K,V>>

Enclosing class:

LockedStreamImpl<K,V>

@ProtoTypeId(1180)
public static class LockedStreamImpl.CacheEntryConsumer<K,V>
extends Object
implements BiConsumer<Cache<K,V>, CacheEntry<K,V>>

Since:

9.0

Author:

wburns

Field Summary

Fields

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

Method Summary

Modifier and Type	Method	Description
void	accept(Cache<K,V> kvCache, CacheEntry<K,V> kvCacheEntry)
protected Void	actualPerform(Cache<K,V> cache, CacheEntry<K,V> entry)

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.BiConsumer

andThen

Field Details

predicate

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

lockManager

protected transient volatile LockManager lockManager

Method Details

accept

public void accept(Cache<K,V> kvCache,
 CacheEntry<K,V> kvCacheEntry)

Specified by:

accept in interface BiConsumer<K,V>

actualPerform

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