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, wrapInReadAction
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
protected boolean processResults(Processor<? super T> consumer)
AbstractQuery
processResults
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