Package aQute.bnd.stream
Class EntryPipeline<K,V>
java.lang.Object
aQute.bnd.stream.EntryPipeline<K,V>
- All Implemented Interfaces:
MapStream<K,
,V> AutoCloseable
,BaseStream<Map.Entry<K,
V>, MapStream<K, V>>
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionboolean
allMatch
(BiPredicate<? super K, ? super V> predicate) boolean
anyMatch
(BiPredicate<? super K, ? super V> predicate) void
close()
<R> R
collect
(Supplier<R> supplier, BiConsumer<R, ? super Map.Entry<? extends K, ? extends V>> accumulator, BiConsumer<R, R> combiner) <R,
A> R private static <K,
V> Comparator<Map.Entry<K, V>> private static <K,
V> Comparator<Map.Entry<K, V>> private static <K,
V> Comparator<Map.Entry<K, V>> long
count()
distinct()
dropWhile
(BiPredicate<? super K, ? super V> predicate) dropWhileKey
(Predicate<? super K> predicate) dropWhileValue
(Predicate<? super V> predicate) entries()
filter
(BiPredicate<? super K, ? super V> filter) filterValue
(Predicate<? super V> filter) findAny()
<R,
S> MapStream<R, S> flatMap
(BiFunction<? super K, ? super V, ? extends MapStream<? extends R, ? extends S>> mapper) flatMapKey
(Function<? super K, ? extends Stream<? extends R>> mapper) flatMapToDouble
(BiFunction<? super K, ? super V, ? extends DoubleStream> mapper) flatMapToInt
(BiFunction<? super K, ? super V, ? extends IntStream> mapper) flatMapToLong
(BiFunction<? super K, ? super V, ? extends LongStream> mapper) <R> Stream<R>
flatMapToObj
(BiFunction<? super K, ? super V, ? extends Stream<? extends R>> mapper) flatMapValue
(Function<? super V, ? extends Stream<? extends S>> mapper) void
forEach
(BiConsumer<? super K, ? super V> consumer) void
forEachOrdered
(BiConsumer<? super K, ? super V> consumer) boolean
iterator()
keys()
limit
(long maxSize) <R,
S> MapStream<R, S> map
(BiFunction<? super K, ? super V, ? extends Map.Entry<? extends R, ? extends S>> mapper) mapToDouble
(ToDoubleBiFunction<? super K, ? super V> mapper) mapToInt
(ToIntBiFunction<? super K, ? super V> mapper) mapToLong
(ToLongBiFunction<? super K, ? super V> mapper) <R> Stream<R>
mapToObj
(BiFunction<? super K, ? super V, ? extends R> mapper) max
(Comparator<? super Map.Entry<K, V>> comparator) maxByKey
(Comparator<? super K> comparator) maxByValue
(Comparator<? super V> comparator) min
(Comparator<? super Map.Entry<K, V>> comparator) minByKey
(Comparator<? super K> comparator) minByValue
(Comparator<? super V> comparator) boolean
noneMatch
(BiPredicate<? super K, ? super V> predicate) parallel()
peek
(BiConsumer<? super K, ? super V> peek) skip
(long n) sorted()
sorted
(Comparator<? super Map.Entry<K, V>> comparator) sortedByKey
(Comparator<? super K> comparator) sortedByValue
(Comparator<? super V> comparator) takeWhile
(BiPredicate<? super K, ? super V> predicate) takeWhileKey
(Predicate<? super K> predicate) takeWhileValue
(Predicate<? super V> predicate) toArray()
values()
-
Field Details
-
stream
-
-
Constructor Details
-
EntryPipeline
-
-
Method Details
-
entries
-
keys
-
values
-
iterator
- Specified by:
iterator
in interfaceBaseStream<K,
V>
-
spliterator
- Specified by:
spliterator
in interfaceBaseStream<K,
V>
-
isParallel
public boolean isParallel()- Specified by:
isParallel
in interfaceBaseStream<K,
V>
-
sequential
- Specified by:
sequential
in interfaceBaseStream<K,
V>
-
parallel
- Specified by:
parallel
in interfaceBaseStream<K,
V>
-
unordered
- Specified by:
unordered
in interfaceBaseStream<K,
V>
-
onClose
- Specified by:
onClose
in interfaceBaseStream<K,
V>
-
close
public void close()- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceBaseStream<K,
V>
-
distinct
-
filter
-
filterKey
-
filterValue
- Specified by:
filterValue
in interfaceMapStream<K,
V>
-
map
public <R,S> MapStream<R,S> map(BiFunction<? super K, ? super V, ? extends Map.Entry<? extends R, ? extends S>> mapper) -
mapKey
-
mapValue
-
mapToObj
-
mapToInt
-
mapToLong
-
mapToDouble
- Specified by:
mapToDouble
in interfaceMapStream<K,
V>
-
flatMap
public <R,S> MapStream<R,S> flatMap(BiFunction<? super K, ? super V, ? extends MapStream<? extends R, ? extends S>> mapper) -
flatMapKey
- Specified by:
flatMapKey
in interfaceMapStream<K,
V>
-
flatMapValue
- Specified by:
flatMapValue
in interfaceMapStream<K,
V>
-
flatMapToObj
public <R> Stream<R> flatMapToObj(BiFunction<? super K, ? super V, ? extends Stream<? extends R>> mapper) - Specified by:
flatMapToObj
in interfaceMapStream<K,
V>
-
flatMapToInt
- Specified by:
flatMapToInt
in interfaceMapStream<K,
V>
-
flatMapToLong
- Specified by:
flatMapToLong
in interfaceMapStream<K,
V>
-
flatMapToDouble
- Specified by:
flatMapToDouble
in interfaceMapStream<K,
V>
-
peek
-
peekKey
-
peekValue
-
comparingByKey
-
comparingByValue
-
comparing
-
sorted
-
sorted
-
sortedByKey
- Specified by:
sortedByKey
in interfaceMapStream<K,
V>
-
sortedByKey
- Specified by:
sortedByKey
in interfaceMapStream<K,
V>
-
sortedByValue
- Specified by:
sortedByValue
in interfaceMapStream<K,
V>
-
sortedByValue
- Specified by:
sortedByValue
in interfaceMapStream<K,
V>
-
limit
-
skip
-
forEach
-
forEachOrdered
- Specified by:
forEachOrdered
in interfaceMapStream<K,
V>
-
count
public long count() -
anyMatch
-
allMatch
-
noneMatch
-
collect
-
collect
public <R> R collect(Supplier<R> supplier, BiConsumer<R, ? super Map.Entry<? extends K, ? extends V>> accumulator, BiConsumer<R, R> combiner) -
max
-
maxByKey
-
maxByValue
- Specified by:
maxByValue
in interfaceMapStream<K,
V>
-
min
-
minByKey
-
minByValue
- Specified by:
minByValue
in interfaceMapStream<K,
V>
-
findAny
-
findFirst
-
toArray
-
takeWhile
-
takeWhileKey
- Specified by:
takeWhileKey
in interfaceMapStream<K,
V>
-
takeWhileValue
- Specified by:
takeWhileValue
in interfaceMapStream<K,
V>
-
dropWhile
-
dropWhileKey
- Specified by:
dropWhileKey
in interfaceMapStream<K,
V>
-
dropWhileValue
- Specified by:
dropWhileValue
in interfaceMapStream<K,
V>
-