Is there any stream equivalent to the following
List<Integer> ints;
while (!(ints = this.nextInts()).isEmpty()) {
// do work
}
Is there any stream equivalent to the following
List<Integer> ints;
while (!(ints = this.nextInts()).isEmpty()) {
// do work
}
first, thanks for the @Olivier Grégoire comments. it change my answer to a new knowledge.
write your own Spliterator
for the unknown size nextInts
, then you can using StreamSupport#stream
to create a stream for nextInts
. for example:
generateUntil(this::nextInts, List::isEmpty).forEach(list -> {
//do works
});
import static java.util.stream.StreamSupport.stream;
<T> Stream<T> generateUntil(final Supplier<T> generator, Predicate<T> stop) {
long unknownSize = Long.MAX_VALUE;
return stream(new AbstractSpliterator<T>(unknownSize, Spliterator.ORDERED) {
@Override
public boolean tryAdvance(Consumer<? super T> action) {
T value = generator.get();
if (stop.test(value)) {
return false;
}
action.accept(value);
return true;
}
}, false);
}