Package org.infinispan.util

Class WriteableCacheCollectionMapper<E,R>

java.lang.Object

java.util.AbstractCollection<R>

org.infinispan.util.CollectionMapper<E,R>

org.infinispan.util.WriteableCacheCollectionMapper<E,R>

Type Parameters:

E - the original collection type - referred to as old in some methods

R - the resulting collection type - referred to as new in some methods

All Implemented Interfaces:

Iterable<R>, Collection<R>, CacheCollection<R>, CloseableIteratorCollection<R>

Direct Known Subclasses:

WriteableCacheSetMapper

public class WriteableCacheCollectionMapper<E,R>
extends CollectionMapper<E,R>
implements CacheCollection<R>

A writeable cache collection mapper that also has constant time operations for things such as Collection.contains(Object) if the underlying Collection does.

This collection should be used for cases when a simple transformation of a element to another is all that is needed by the underlying collection.

Note this class allows for a different function specifically for values returned from an iterator. This can be useful to intercept calls such as Map.Entry.setValue(Object) and update appropriately.

Since:

9.2

Author:

wburns

Field Summary

Fields

Modifier and Type	Field	Description
protected final Function<? super R,? extends E>	fromNewTypeFunction
protected final InjectiveFunction<Object,?>	keyFilterMapper
protected final CacheCollection<E>	realCacheCollection
protected final Function<? super E,? extends R>	toNewTypeIteratorFunction

Fields inherited from class org.infinispan.util.CollectionMapper

mapper, realCollection

Constructor Summary

Constructors

Constructor	Description
WriteableCacheCollectionMapper(CacheCollection<E> realCollection, Function<? super E,? extends R> toNewTypeFunction, Function<? super E,? extends R> toNewTypeIteratorFunction, Function<? super R,? extends E> fromNewTypeFunction, InjectiveFunction<Object,?> keyFilterFunction)
WriteableCacheCollectionMapper(CacheCollection<E> realCollection, Function<? super E,? extends R> toNewTypeFunction, Function<? super R,? extends E> fromNewTypeFunction, InjectiveFunction<Object,?> keyFilterFunction)

Method Summary

Modifier and Type	Method	Description
boolean	add(R e)
boolean	addAll(Collection<? extends R> c)
void	clear()
boolean	contains(Object o)
boolean	containsAll(Collection<?> c)
CloseableIterator<R>	iterator()
CacheStream<R>	parallelStream()
boolean	remove(Object o)
boolean	removeAll(Collection<?> c)
boolean	removeIf(Predicate<? super R> filter)
boolean	retainAll(Collection<?> c)
CloseableSpliterator<R>	spliterator()
CacheStream<R>	stream()

Methods inherited from class org.infinispan.util.CollectionMapper

forEach, isEmpty, size

Methods inherited from class java.util.AbstractCollection

toArray, toArray, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.CacheCollection

localPublisher, localPublisher

Methods inherited from interface java.util.Collection

equals, hashCode, isEmpty, size, toArray, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Field Details

realCacheCollection

protected final CacheCollection<E> realCacheCollection

toNewTypeIteratorFunction

protected final Function<? super E,? extends R> toNewTypeIteratorFunction

fromNewTypeFunction

protected final Function<? super R,? extends E> fromNewTypeFunction

keyFilterMapper

protected final InjectiveFunction<Object,?> keyFilterMapper

Constructor Details

WriteableCacheCollectionMapper

public WriteableCacheCollectionMapper(CacheCollection<E> realCollection,
 Function<? super E,? extends R> toNewTypeFunction,
 Function<? super R,? extends E> fromNewTypeFunction,
 InjectiveFunction<Object,?> keyFilterFunction)

WriteableCacheCollectionMapper

public WriteableCacheCollectionMapper(CacheCollection<E> realCollection,
 Function<? super E,? extends R> toNewTypeFunction,
 Function<? super E,? extends R> toNewTypeIteratorFunction,
 Function<? super R,? extends E> fromNewTypeFunction,
 InjectiveFunction<Object,?> keyFilterFunction)

Method Details

iterator

public CloseableIterator<R> iterator()

Description copied from interface: CloseableIteratorCollection

This iterator should be explicitly closed when iteration upon it is completed. Failure to do so could cause resources to not be freed properly

Specified by:

iterator in interface CloseableIteratorCollection<E>

Specified by:

iterator in interface Collection<E>

Specified by:

iterator in interface Iterable<E>

Overrides:

iterator in class CollectionMapper<E,R>

contains

public boolean contains(Object o)

Specified by:

contains in interface Collection<E>

Overrides:

contains in class AbstractCollection<R>

containsAll

public boolean containsAll(Collection<?> c)

Specified by:

containsAll in interface Collection<E>

Overrides:

containsAll in class AbstractCollection<R>

add

public boolean add(R e)

Specified by:

add in interface Collection<E>

Overrides:

add in class CollectionMapper<E,R>

addAll

public boolean addAll(Collection<? extends R> c)

Specified by:

addAll in interface Collection<E>

Overrides:

addAll in class CollectionMapper<E,R>

remove

public boolean remove(Object o)

Specified by:

remove in interface Collection<E>

Overrides:

remove in class CollectionMapper<E,R>

removeAll

public boolean removeAll(Collection<?> c)

Specified by:

removeAll in interface Collection<E>

Overrides:

removeAll in class CollectionMapper<E,R>

retainAll

public boolean retainAll(Collection<?> c)

Specified by:

retainAll in interface Collection<E>

Overrides:

retainAll in class CollectionMapper<E,R>

removeIf

public boolean removeIf(Predicate<? super R> filter)

Specified by:

removeIf in interface Collection<E>

clear

public void clear()

Specified by:

clear in interface Collection<E>

Overrides:

clear in class CollectionMapper<E,R>

spliterator

public CloseableSpliterator<R> spliterator()

Description copied from interface: CloseableIteratorCollection

This spliterator should be explicitly closed after it has been used. Failure to do so could cause resources to not be freed properly

Specified by:

spliterator in interface CloseableIteratorCollection<E>

Specified by:

spliterator in interface Collection<E>

Specified by:

spliterator in interface Iterable<E>

Overrides:

spliterator in class CollectionMapper<E,R>

stream

public CacheStream<R> stream()

Description copied from interface: CloseableIteratorCollection

This stream should be explicitly closed after it has been used. Failure to do so could cause resources to not be freed properly

Specified by:

stream in interface CacheCollection<E>

Specified by:

stream in interface CloseableIteratorCollection<E>

Specified by:

stream in interface Collection<E>

Overrides:

stream in class CollectionMapper<E,R>

parallelStream

public CacheStream<R> parallelStream()

Description copied from interface: CloseableIteratorCollection

This stream should be explicitly closed after it has been used. Failure to do so could cause resources to not be freed properly

Specified by:

parallelStream in interface CacheCollection<E>

Specified by:

parallelStream in interface CloseableIteratorCollection<E>

Specified by:

parallelStream in interface Collection<E>

Overrides:

parallelStream in class CollectionMapper<E,R>