public class UniqueResultsQuery<T,M> extends AbstractQuery<T>
| Constructor and Description |
|---|
UniqueResultsQuery(Query<? extends T> original) |
UniqueResultsQuery(Query<? extends T> original,
<any> hashingStrategy) |
UniqueResultsQuery(Query<? extends T> original,
<any> hashingStrategy,
Function<? super T,? extends M> mapper) |
| Modifier and Type | Method and Description |
|---|---|
AsyncFuture<java.lang.Boolean> |
forEachAsync(Processor<? super T> consumer) |
protected boolean |
processResults(Processor<? super T> consumer)
Assumes consumer being capable of processing results in parallel
|
java.lang.String |
toString() |
allowParallelProcessing, delegateProcessResults, findAll, findFirst, forEach, iterator, toArray, wrapInReadActionclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitprotected boolean processResults(Processor<? super T> consumer)
AbstractQueryprocessResults in class AbstractQuery<T>public AsyncFuture<java.lang.Boolean> forEachAsync(Processor<? super T> consumer)
forEachAsync in interface Query<T>forEachAsync in class AbstractQuery<T>public java.lang.String toString()
toString in class java.lang.Object