diff options
author | kurczews <krzysztof.kurczewski@nokia.com> | 2018-08-13 13:40:47 +0200 |
---|---|---|
committer | kurczews <krzysztof.kurczewski@nokia.com> | 2018-08-13 13:43:12 +0200 |
commit | 2513c3cae11dbc717d2c22ffdd8266aa2e61a800 (patch) | |
tree | 7c1a9c1630be657506995f4a291504562bf712b1 /vid-automation/src/test/java/org/opencomp/vid/api/Streams.java | |
parent | 9b45c01d9bb3a4565ed64c20e72511edc0854636 (diff) |
Renaming vid-automation #4
Change-Id: I907b9a6c199302d748918e236ee2945d56f4dd26
Issue-ID: VID-205
Signed-off-by: kurczews <krzysztof.kurczewski@nokia.com>
Diffstat (limited to 'vid-automation/src/test/java/org/opencomp/vid/api/Streams.java')
-rw-r--r-- | vid-automation/src/test/java/org/opencomp/vid/api/Streams.java | 47 |
1 files changed, 0 insertions, 47 deletions
diff --git a/vid-automation/src/test/java/org/opencomp/vid/api/Streams.java b/vid-automation/src/test/java/org/opencomp/vid/api/Streams.java deleted file mode 100644 index c1c6cea4..00000000 --- a/vid-automation/src/test/java/org/opencomp/vid/api/Streams.java +++ /dev/null @@ -1,47 +0,0 @@ -package org.opencomp.vid.api; - -import java.util.Iterator; -import java.util.Spliterator; -import java.util.Spliterators; -import java.util.function.Consumer; -import java.util.function.Predicate; -import java.util.stream.Stream; -import java.util.stream.StreamSupport; - -public class Streams { - public static <R> Predicate<R> not(Predicate<R> predicate) { - return predicate.negate(); - } - - public static <T> Stream<T> fromIterator(final Iterator<T> iterator) { - Iterable<T> iterable = () -> iterator; - return StreamSupport.<T>stream(iterable.spliterator(), false); - } - - - // https://stackoverflow.com/questions/20746429/limit-a-stream-by-a-predicate - private static <T> Spliterator<T> takeWhile( - Spliterator<T> splitr, Predicate<? super T> predicate) { - return new Spliterators.AbstractSpliterator<T>(splitr.estimateSize(), 0) { - boolean stillGoing = true; - @Override public boolean tryAdvance(Consumer<? super T> consumer) { - if (stillGoing) { - boolean hadNext = splitr.tryAdvance(elem -> { - if (predicate.test(elem)) { - consumer.accept(elem); - } else { - stillGoing = false; - } - }); - return hadNext && stillGoing; - } - return false; - } - }; - } - - public static <T> Stream<T> takeWhile(Stream<T> stream, Predicate<? super T> predicate) { - return StreamSupport.stream(takeWhile(stream.spliterator(), predicate), false); - } - -} |