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>>

final class EntryPipeline<K,V>
extends Object
implements MapStream<K,V>

Field Summary

Fields

Modifier and Type	Field	Description
private final Stream<Map.Entry<K,V>>	stream

Constructor Summary

Constructors

Constructor	Description
EntryPipeline(Stream<? extends Map.Entry<? extends K,? extends V>> stream)

Method Summary

Modifier and Type	Method	Description
boolean	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	collect(Collector<? super Map.Entry<? extends K,? extends V>,A,R> collector)
private static <K, V> Comparator<Map.Entry<K,V>>	comparing()
private static <K, V> Comparator<Map.Entry<K,V>>	comparingByKey()
private static <K, V> Comparator<Map.Entry<K,V>>	comparingByValue()
long	count()
MapStream<K,V>	distinct()
MapStream<K,V>	dropWhile(BiPredicate<? super K,? super V> predicate)
MapStream<K,V>	dropWhileKey(Predicate<? super K> predicate)
MapStream<K,V>	dropWhileValue(Predicate<? super V> predicate)
Stream<Map.Entry<K,V>>	entries()
MapStream<K,V>	filter(BiPredicate<? super K,? super V> filter)
MapStream<K,V>	filterKey(Predicate<? super K> filter)
MapStream<K,V>	filterValue(Predicate<? super V> filter)
Optional<Map.Entry<K,V>>	findAny()
Optional<Map.Entry<K,V>>	findFirst()
<R, S> MapStream<R,S>	flatMap(BiFunction<? super K,? super V,? extends MapStream<? extends R,? extends S>> mapper)
<R> MapStream<R,V>	flatMapKey(Function<? super K,? extends Stream<? extends R>> mapper)
DoubleStream	flatMapToDouble(BiFunction<? super K,? super V,? extends DoubleStream> mapper)
IntStream	flatMapToInt(BiFunction<? super K,? super V,? extends IntStream> mapper)
LongStream	flatMapToLong(BiFunction<? super K,? super V,? extends LongStream> mapper)
<R> Stream<R>	flatMapToObj(BiFunction<? super K,? super V,? extends Stream<? extends R>> mapper)
<S> MapStream<K,S>	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	isParallel()
Iterator<Map.Entry<K,V>>	iterator()
Stream<K>	keys()
MapStream<K,V>	limit(long maxSize)
<R, S> MapStream<R,S>	map(BiFunction<? super K,? super V,? extends Map.Entry<? extends R,? extends S>> mapper)
<R> MapStream<R,V>	mapKey(Function<? super K,? extends R> mapper)
DoubleStream	mapToDouble(ToDoubleBiFunction<? super K,? super V> mapper)
IntStream	mapToInt(ToIntBiFunction<? super K,? super V> mapper)
LongStream	mapToLong(ToLongBiFunction<? super K,? super V> mapper)
<R> Stream<R>	mapToObj(BiFunction<? super K,? super V,? extends R> mapper)
<S> MapStream<K,S>	mapValue(Function<? super V,? extends S> mapper)
Optional<Map.Entry<K,V>>	max(Comparator<? super Map.Entry<K,V>> comparator)
Optional<Map.Entry<K,V>>	maxByKey(Comparator<? super K> comparator)
Optional<Map.Entry<K,V>>	maxByValue(Comparator<? super V> comparator)
Optional<Map.Entry<K,V>>	min(Comparator<? super Map.Entry<K,V>> comparator)
Optional<Map.Entry<K,V>>	minByKey(Comparator<? super K> comparator)
Optional<Map.Entry<K,V>>	minByValue(Comparator<? super V> comparator)
boolean	noneMatch(BiPredicate<? super K,? super V> predicate)
MapStream<K,V>	onClose(Runnable closeHandler)
MapStream<K,V>	parallel()
MapStream<K,V>	peek(BiConsumer<? super K,? super V> peek)
MapStream<K,V>	peekKey(Consumer<? super K> peek)
MapStream<K,V>	peekValue(Consumer<? super V> peek)
MapStream<K,V>	sequential()
MapStream<K,V>	skip(long n)
MapStream<K,V>	sorted()
MapStream<K,V>	sorted(Comparator<? super Map.Entry<K,V>> comparator)
MapStream<K,V>	sortedByKey()
MapStream<K,V>	sortedByKey(Comparator<? super K> comparator)
MapStream<K,V>	sortedByValue()
MapStream<K,V>	sortedByValue(Comparator<? super V> comparator)
Spliterator<Map.Entry<K,V>>	spliterator()
MapStream<K,V>	takeWhile(BiPredicate<? super K,? super V> predicate)
MapStream<K,V>	takeWhileKey(Predicate<? super K> predicate)
MapStream<K,V>	takeWhileValue(Predicate<? super V> predicate)
Map.Entry<K,V>[]	toArray()
MapStream<K,V>	unordered()
Stream<V>	values()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

stream

private final Stream<Map.Entry<K,V>> stream

Constructor Details

EntryPipeline

EntryPipeline(Stream<? extends Map.Entry<? extends K,? extends V>> stream)

Method Details

entries

public Stream<Map.Entry<K,V>> entries()

Specified by:

entries in interface MapStream<K,V>

keys

public Stream<K> keys()

Specified by:

keys in interface MapStream<K,V>

values

public Stream<V> values()

Specified by:

values in interface MapStream<K,V>

iterator

public Iterator<Map.Entry<K,V>> iterator()

Specified by:

iterator in interface BaseStream<K,V>

spliterator

public Spliterator<Map.Entry<K,V>> spliterator()

Specified by:

spliterator in interface BaseStream<K,V>

isParallel

public boolean isParallel()

Specified by:

isParallel in interface BaseStream<K,V>

sequential

public MapStream<K,V> sequential()

Specified by:

sequential in interface BaseStream<K,V>

parallel

public MapStream<K,V> parallel()

Specified by:

parallel in interface BaseStream<K,V>

unordered

public MapStream<K,V> unordered()

Specified by:

unordered in interface BaseStream<K,V>

onClose

public MapStream<K,V> onClose(Runnable closeHandler)

Specified by:

onClose in interface BaseStream<K,V>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface BaseStream<K,V>

distinct

public MapStream<K,V> distinct()

Specified by:

distinct in interface MapStream<K,V>

filter

public MapStream<K,V> filter(BiPredicate<? super K,? super V> filter)

Specified by:

filter in interface MapStream<K,V>

filterKey

public MapStream<K,V> filterKey(Predicate<? super K> filter)

Specified by:

filterKey in interface MapStream<K,V>

filterValue

public MapStream<K,V> filterValue(Predicate<? super V> filter)

Specified by:

filterValue in interface MapStream<K,V>

map

public <R,
S> MapStream<R,S> map(BiFunction<? super K,? super V,? extends Map.Entry<? extends R,? extends S>> mapper)

Specified by:

map in interface MapStream<K,V>

mapKey

public <R> MapStream<R,V> mapKey(Function<? super K,? extends R> mapper)

Specified by:

mapKey in interface MapStream<K,V>

mapValue

public <S> MapStream<K,S> mapValue(Function<? super V,? extends S> mapper)

Specified by:

mapValue in interface MapStream<K,V>

mapToObj

public <R> Stream<R> mapToObj(BiFunction<? super K,? super V,? extends R> mapper)

Specified by:

mapToObj in interface MapStream<K,V>

mapToInt

public IntStream mapToInt(ToIntBiFunction<? super K,? super V> mapper)

Specified by:

mapToInt in interface MapStream<K,V>

mapToLong

public LongStream mapToLong(ToLongBiFunction<? super K,? super V> mapper)

Specified by:

mapToLong in interface MapStream<K,V>

mapToDouble

public DoubleStream mapToDouble(ToDoubleBiFunction<? super K,? super V> mapper)

Specified by:

mapToDouble in interface MapStream<K,V>

flatMap

public <R,
S> MapStream<R,S> flatMap(BiFunction<? super K,? super V,? extends MapStream<? extends R,? extends S>> mapper)

Specified by:

flatMap in interface MapStream<K,V>

flatMapKey

public <R> MapStream<R,V> flatMapKey(Function<? super K,? extends Stream<? extends R>> mapper)

Specified by:

flatMapKey in interface MapStream<K,V>

flatMapValue

public <S> MapStream<K,S> flatMapValue(Function<? super V,? extends Stream<? extends S>> mapper)

Specified by:

flatMapValue in interface MapStream<K,V>

flatMapToObj

public <R> Stream<R> flatMapToObj(BiFunction<? super K,? super V,? extends Stream<? extends R>> mapper)

Specified by:

flatMapToObj in interface MapStream<K,V>

flatMapToInt

public IntStream flatMapToInt(BiFunction<? super K,? super V,? extends IntStream> mapper)

Specified by:

flatMapToInt in interface MapStream<K,V>

flatMapToLong

public LongStream flatMapToLong(BiFunction<? super K,? super V,? extends LongStream> mapper)

Specified by:

flatMapToLong in interface MapStream<K,V>

flatMapToDouble

public DoubleStream flatMapToDouble(BiFunction<? super K,? super V,? extends DoubleStream> mapper)

Specified by:

flatMapToDouble in interface MapStream<K,V>

peek

public MapStream<K,V> peek(BiConsumer<? super K,? super V> peek)

Specified by:

peek in interface MapStream<K,V>

peekKey

public MapStream<K,V> peekKey(Consumer<? super K> peek)

Specified by:

peekKey in interface MapStream<K,V>

peekValue

public MapStream<K,V> peekValue(Consumer<? super V> peek)

Specified by:

peekValue in interface MapStream<K,V>

comparingByKey

private static <K,
V> Comparator<Map.Entry<K,V>> comparingByKey()

comparingByValue

private static <K,
V> Comparator<Map.Entry<K,V>> comparingByValue()

comparing

private static <K,
V> Comparator<Map.Entry<K,V>> comparing()

sorted

public MapStream<K,V> sorted()

Specified by:

sorted in interface MapStream<K,V>

sorted

public MapStream<K,V> sorted(Comparator<? super Map.Entry<K,V>> comparator)

Specified by:

sorted in interface MapStream<K,V>

sortedByKey

public MapStream<K,V> sortedByKey()

Specified by:

sortedByKey in interface MapStream<K,V>

sortedByKey

public MapStream<K,V> sortedByKey(Comparator<? super K> comparator)

Specified by:

sortedByKey in interface MapStream<K,V>

sortedByValue

public MapStream<K,V> sortedByValue()

Specified by:

sortedByValue in interface MapStream<K,V>

sortedByValue

public MapStream<K,V> sortedByValue(Comparator<? super V> comparator)

Specified by:

sortedByValue in interface MapStream<K,V>

limit

public MapStream<K,V> limit(long maxSize)

Specified by:

limit in interface MapStream<K,V>

skip

public MapStream<K,V> skip(long n)

Specified by:

skip in interface MapStream<K,V>

forEach

public void forEach(BiConsumer<? super K,? super V> consumer)

Specified by:

forEach in interface MapStream<K,V>

forEachOrdered

public void forEachOrdered(BiConsumer<? super K,? super V> consumer)

Specified by:

forEachOrdered in interface MapStream<K,V>

count

public long count()

Specified by:

count in interface MapStream<K,V>

anyMatch

public boolean anyMatch(BiPredicate<? super K,? super V> predicate)

Specified by:

anyMatch in interface MapStream<K,V>

allMatch

public boolean allMatch(BiPredicate<? super K,? super V> predicate)

Specified by:

allMatch in interface MapStream<K,V>

noneMatch

public boolean noneMatch(BiPredicate<? super K,? super V> predicate)

Specified by:

noneMatch in interface MapStream<K,V>

collect

public <R,
A> R collect(Collector<? super Map.Entry<? extends K,? extends V>,A,R> collector)

Specified by:

collect in interface MapStream<K,V>

collect

public <R> R collect(Supplier<R> supplier,
 BiConsumer<R,? super Map.Entry<? extends K,? extends V>> accumulator,
 BiConsumer<R,R> combiner)

Specified by:

collect in interface MapStream<K,V>

max

public Optional<Map.Entry<K,V>> max(Comparator<? super Map.Entry<K,V>> comparator)

Specified by:

max in interface MapStream<K,V>

maxByKey

public Optional<Map.Entry<K,V>> maxByKey(Comparator<? super K> comparator)

Specified by:

maxByKey in interface MapStream<K,V>

maxByValue

public Optional<Map.Entry<K,V>> maxByValue(Comparator<? super V> comparator)

Specified by:

maxByValue in interface MapStream<K,V>

min

public Optional<Map.Entry<K,V>> min(Comparator<? super Map.Entry<K,V>> comparator)

Specified by:

min in interface MapStream<K,V>

minByKey

public Optional<Map.Entry<K,V>> minByKey(Comparator<? super K> comparator)

Specified by:

minByKey in interface MapStream<K,V>

minByValue

public Optional<Map.Entry<K,V>> minByValue(Comparator<? super V> comparator)

Specified by:

minByValue in interface MapStream<K,V>

findAny

public Optional<Map.Entry<K,V>> findAny()

Specified by:

findAny in interface MapStream<K,V>

findFirst

public Optional<Map.Entry<K,V>> findFirst()

Specified by:

findFirst in interface MapStream<K,V>

toArray

public Map.Entry<K,V>[] toArray()

Specified by:

toArray in interface MapStream<K,V>

takeWhile

public MapStream<K,V> takeWhile(BiPredicate<? super K,? super V> predicate)

Specified by:

takeWhile in interface MapStream<K,V>

takeWhileKey

public MapStream<K,V> takeWhileKey(Predicate<? super K> predicate)

Specified by:

takeWhileKey in interface MapStream<K,V>

takeWhileValue

public MapStream<K,V> takeWhileValue(Predicate<? super V> predicate)

Specified by:

takeWhileValue in interface MapStream<K,V>

dropWhile

public MapStream<K,V> dropWhile(BiPredicate<? super K,? super V> predicate)

Specified by:

dropWhile in interface MapStream<K,V>

dropWhileKey

public MapStream<K,V> dropWhileKey(Predicate<? super K> predicate)

Specified by:

dropWhileKey in interface MapStream<K,V>

dropWhileValue

public MapStream<K,V> dropWhileValue(Predicate<? super V> predicate)

Specified by:

dropWhileValue in interface MapStream<K,V>