This commit is contained in:
@@ -266,9 +266,7 @@ public final class EntityCache<T> {
|
|||||||
Stream<T> stream = listStream();
|
Stream<T> stream = listStream();
|
||||||
if (filter != null) stream = stream.filter(filter);
|
if (filter != null) stream = stream.filter(filter);
|
||||||
if (sort != null) stream = stream.sorted(sort);
|
if (sort != null) stream = stream.sorted(sort);
|
||||||
if (flipper != null) {
|
if (flipper != null) stream = stream.skip(flipper.index()).limit(flipper.getSize());
|
||||||
stream = stream.skip(flipper.index()).limit(flipper.getSize());
|
|
||||||
}
|
|
||||||
boolean parallel = isParallel();
|
boolean parallel = isParallel();
|
||||||
final List<T> rs = parallel ? new CopyOnWriteArrayList<>() : new ArrayList<>();
|
final List<T> rs = parallel ? new CopyOnWriteArrayList<>() : new ArrayList<>();
|
||||||
if (selects == null) {
|
if (selects == null) {
|
||||||
|
|||||||
Reference in New Issue
Block a user