diff options
Diffstat (limited to 'common-app-api/src/main/java/org/openecomp/sdc/common/util/StreamUtils.java')
-rw-r--r-- | common-app-api/src/main/java/org/openecomp/sdc/common/util/StreamUtils.java | 29 |
1 files changed, 14 insertions, 15 deletions
diff --git a/common-app-api/src/main/java/org/openecomp/sdc/common/util/StreamUtils.java b/common-app-api/src/main/java/org/openecomp/sdc/common/util/StreamUtils.java index 90371a3403..2d07069388 100644 --- a/common-app-api/src/main/java/org/openecomp/sdc/common/util/StreamUtils.java +++ b/common-app-api/src/main/java/org/openecomp/sdc/common/util/StreamUtils.java @@ -51,7 +51,7 @@ public final class StreamUtils { */ public static <T> Stream<T> takeWhilePlusOneNoEval(Stream<T> stream, Predicate<T> predicate) { List<T> results = new ArrayList<>(); - Consumer<T> listAdder = e -> results.add(e); + Consumer<T> listAdder = results::add; stream.map(e -> { listAdder.accept(e); return e; @@ -64,11 +64,11 @@ public final class StreamUtils { } public static <T> Stream<T> takeWhilePlusOne(Stream<T> stream, Predicate<T> predicate) { - return StreamSupport.stream(takeWhile(stream.spliterator(), new StopAfterFailPredicate<T>(predicate)), false); + return StreamSupport.stream(takeWhile(stream.spliterator(), new StopAfterFailPredicate<>(predicate)), false); } private static <T> Spliterator<T> takeWhile(Spliterator<T> splitr, Predicate<T> predicate) { - return new MySplitIterator<T>(splitr, predicate); + return new MySplitIterator<>(splitr, predicate); } public static class MySplitIterator<T> extends AbstractSpliterator<T> implements Spliterator<T> { @@ -94,18 +94,17 @@ public final class StreamUtils { } private Consumer<? super T> createConsumerWrapper(Consumer<? super T> action) { - Consumer<? super T> cons = new Consumer<T>() { - @Override - public void accept(T t) { - stillGoing = innerPred.test(t); - if (stillGoing) { - action.accept(t); - } - - } - }; - - return cons; + + return new Consumer<T>() { + @Override + public void accept(T t) { + stillGoing = innerPred.test(t); + if (stillGoing) { + action.accept(t); + } + + } + }; } } |