|
@@ -293,21 +293,24 @@ public abstract class CQueryAbstract<T> implements CQuery<T> {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public final void each(Consumer<? super T> consumer) {
|
|
|
|
|
|
|
+ public final CQuery<T> each(Consumer<? super T> consumer) {
|
|
|
stream().forEach(consumer);
|
|
stream().forEach(consumer);
|
|
|
|
|
+ return this;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public final void each(EachConsumer<? super T> consumer) {
|
|
|
|
|
|
|
+ public final CQuery<T> each(EachConsumer<? super T> consumer) {
|
|
|
int index = 0;
|
|
int index = 0;
|
|
|
for (T t : this) {
|
|
for (T t : this) {
|
|
|
consumer.apply(index++, t);
|
|
consumer.apply(index++, t);
|
|
|
}
|
|
}
|
|
|
|
|
+ return this;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|
|
|
- public void into(Collection<? super T> collection) {
|
|
|
|
|
|
|
+ public CQuery<T> into(Collection<? super T> collection) {
|
|
|
stream().forEach(collection::add);
|
|
stream().forEach(collection::add);
|
|
|
|
|
+ return this;
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Override
|
|
@Override
|