java.lang.Object

org.tquadrat.foundation.stream.internal.DefaultMapStream<K,V>

Type Parameters:: K - The type of the map keys.; V - The type of the map values.

All Implemented Interfaces:: AutoCloseable, BaseStream<Map.Entry<K,V>, Stream<Map.Entry<K,V>>>, Stream<Map.Entry<K,V>>, MapStream<K,V>

@ClassVersion(sourceVersion="$Id: DefaultMapStream.java 1151 2025-10-01 21:32:15Z tquadrat $") @API(status=INTERNAL, since="0.0.7") public final class DefaultMapStream<K,V> extends Object implements MapStream<K,V>

The default implementation for MapStream.

Author:: Alexis Cartier (alexcrt), Dominic Fox
Modified by:: Thomas Thrien (thomas.thrien@tquadrat.org)
Version:: $Id: DefaultMapStream.java 1151 2025-10-01 21:32:15Z tquadrat $
Since:: 0.0.7
UML Diagram: ⁠
UML Diagram for "org.tquadrat.foundation.stream.internal.DefaultMapStream"
⁠

Nested Class Summary

Nested classes/interfaces inherited from interface Stream
Stream.Builder<T>
Field Summary

Fields

Modifier and Type

Field

Description

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

m_Delegate

The wrapped stream.
Constructor Summary

Constructors

Constructor

Description

DefaultMapStream(Stream<Map.Entry<K,V>> stream)

Creates a new DefaultMapStream instance from the provided stream.
Method Summary

Modifier and Type

Method

Description

final boolean

allMatch(Predicate<? super Map.Entry<K,V>> predicate)

final boolean

anyMatch(Predicate<? super Map.Entry<K,V>> predicate)

final void

close()

final <R> R

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

final <R,A> R

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

final long

count()

final MapStream<K,V>

distinct()

final MapStream<K,V>

filter(Predicate<? super Map.Entry<K,V>> predicate)

final Optional<Map.Entry<K,V>>

findAny()

final Optional<Map.Entry<K,V>>

findFirst()

final <R> Stream<R>

flatMap(Function<? super Map.Entry<K,V>, ? extends Stream<? extends R>> mapper)

final DoubleStream

flatMapToDouble(Function<? super Map.Entry<K,V>, ? extends DoubleStream> mapper)

final IntStream

flatMapToInt(Function<? super Map.Entry<K,V>, ? extends IntStream> mapper)

final LongStream

flatMapToLong(Function<? super Map.Entry<K,V>, ? extends LongStream> mapper)

final void

forEach(Consumer<? super Map.Entry<K,V>> action)

final void

forEachOrdered(Consumer<? super Map.Entry<K,V>> action)

final boolean

isParallel()

final Iterator<Map.Entry<K,V>>

iterator()

final MapStream<K,V>

limit(long limit)

final <R> Stream<R>

map(Function<? super Map.Entry<K,V>, ? extends R> mapper)

final DoubleStream

mapToDouble(ToDoubleFunction<? super Map.Entry<K,V>> mapper)

final IntStream

mapToInt(ToIntFunction<? super Map.Entry<K,V>> mapper)

final LongStream

mapToLong(ToLongFunction<? super Map.Entry<K,V>> mapper)

final Optional<Map.Entry<K,V>>

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

final Optional<Map.Entry<K,V>>

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

final boolean

noneMatch(Predicate<? super Map.Entry<K,V>> predicate)

final MapStream<K,V>

onClose(Runnable closeHandler)

final MapStream<K,V>

parallel()

final MapStream<K,V>

peek(Consumer<? super Map.Entry<K,V>> action)

final Optional<Map.Entry<K,V>>

reduce(BinaryOperator<Map.Entry<K,V>> accumulator)

final Map.Entry<K,V>

reduce(Map.Entry<K,V> identity, BinaryOperator<Map.Entry<K,V>> accumulator)

final <U> U

reduce(U identity, BiFunction<U, ? super Map.Entry<K,V>, U> accumulator, BinaryOperator<U> combiner)

final MapStream<K,V>

sequential()

final MapStream<K,V>

skip(long n)

final MapStream<K,V>

sorted()

final MapStream<K,V>

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

final Spliterator<Map.Entry<K,V>>

spliterator()

final Object[]

toArray()

final <A> A[]

toArray(IntFunction<A[]> generator)

final MapStream<K,V>

unordered()

Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface MapStream
collect, collect, dropKeys, dropValues, filter, forEach, inverseMapping, map, mapEntries, mapKeys, mapValues, mergeKeys, mergeKeys

Methods inherited from interface Stream
dropWhile, gather, mapMulti, mapMultiToDouble, mapMultiToInt, mapMultiToLong, takeWhile, toList

Field Details
- m_Delegate
  
  private final Stream<Map.Entry<K,V>> m_Delegate
  
  The wrapped stream.
Constructor Details
- DefaultMapStream
  
  public DefaultMapStream(Stream<Map.Entry<K,V>> stream)
  
  Creates a new DefaultMapStream instance from the provided stream.
  
  Parameters:
  
  stream - The stream to wrap.
Method Details
- allMatch
  
  public final boolean allMatch(Predicate<? super Map.Entry<K,V>> predicate)
  
  Specified by:
  
  allMatch in interface Stream<K>
- anyMatch
  
  public final boolean anyMatch(Predicate<? super Map.Entry<K,V>> predicate)
  
  Specified by:
  
  anyMatch in interface Stream<K>
- close
  
  public final void close()
  
  Specified by:
  
  close in interface AutoCloseable
  
  Specified by:
  
  close in interface BaseStream<K,V>
- collect
  
  public final <R,A> R collect(Collector<? super Map.Entry<K,V>, A, R> collector)
  
  Specified by:
  
  collect in interface Stream<K>
- collect
  
  public final <R> R collect(Supplier<R> supplier, BiConsumer<R, ? super Map.Entry<K,V>> accumulator, BiConsumer<R,R> combiner)
  
  Specified by:
  
  collect in interface Stream<K>
- count
  
  public final long count()
  
  Specified by:
  
  count in interface Stream<K>
- distinct
  
  public final MapStream<K,V> distinct()
  
  Specified by:
  
  distinct in interface MapStream<K,V>
  
  Specified by:
  
  distinct in interface Stream<K>
- filter
  
  public final MapStream<K,V> filter(Predicate<? super Map.Entry<K,V>> predicate)
  
  Specified by:
  
  filter in interface MapStream<K,V>
  
  Specified by:
  
  filter in interface Stream<K>
- findAny
  
  public final Optional<Map.Entry<K,V>> findAny()
  
  Specified by:
  
  findAny in interface Stream<K>
- findFirst
  
  public final Optional<Map.Entry<K,V>> findFirst()
  
  Specified by:
  
  findFirst in interface Stream<K>
- flatMap
  
  public final <R> Stream<R> flatMap(Function<? super Map.Entry<K,V>, ? extends Stream<? extends R>> mapper)
  
  Specified by:
  
  flatMap in interface Stream<K>
- flatMapToDouble
  
  public final DoubleStream flatMapToDouble(Function<? super Map.Entry<K,V>, ? extends DoubleStream> mapper)
  
  Specified by:
  
  flatMapToDouble in interface Stream<K>
- flatMapToInt
  
  public final IntStream flatMapToInt(Function<? super Map.Entry<K,V>, ? extends IntStream> mapper)
  
  Specified by:
  
  flatMapToInt in interface Stream<K>
- flatMapToLong
  
  public final LongStream flatMapToLong(Function<? super Map.Entry<K,V>, ? extends LongStream> mapper)
  
  Specified by:
  
  flatMapToLong in interface Stream<K>
- forEach
  
  public final void forEach(Consumer<? super Map.Entry<K,V>> action)
  
  Specified by:
  
  forEach in interface Stream<K>
- forEachOrdered
  
  public final void forEachOrdered(Consumer<? super Map.Entry<K,V>> action)
  
  Specified by:
  
  forEachOrdered in interface Stream<K>
- isParallel
  
  public final boolean isParallel()
  
  Specified by:
  
  isParallel in interface BaseStream<K,V>
- iterator
  
  public final Iterator<Map.Entry<K,V>> iterator()
  
  Specified by:
  
  iterator in interface BaseStream<K,V>
- limit
  
  public final MapStream<K,V> limit(long limit)
  
  Specified by:
  
  limit in interface MapStream<K,V>
  
  Specified by:
  
  limit in interface Stream<K>
- map
  
  public final <R> Stream<R> map(Function<? super Map.Entry<K,V>, ? extends R> mapper)
  
  Specified by:
  
  map in interface Stream<K>
- mapToDouble
  
  public final DoubleStream mapToDouble(ToDoubleFunction<? super Map.Entry<K,V>> mapper)
  
  Specified by:
  
  mapToDouble in interface Stream<K>
- mapToInt
  
  public final IntStream mapToInt(ToIntFunction<? super Map.Entry<K,V>> mapper)
  
  Specified by:
  
  mapToInt in interface Stream<K>
- mapToLong
  
  public final LongStream mapToLong(ToLongFunction<? super Map.Entry<K,V>> mapper)
  
  Specified by:
  
  mapToLong in interface Stream<K>
- max
  
  public final Optional<Map.Entry<K,V>> max(Comparator<? super Map.Entry<K,V>> comparator)
  
  Specified by:
  
  max in interface Stream<K>
- min
  
  public final Optional<Map.Entry<K,V>> min(Comparator<? super Map.Entry<K,V>> comparator)
  
  Specified by:
  
  min in interface Stream<K>
- noneMatch
  
  public final boolean noneMatch(Predicate<? super Map.Entry<K,V>> predicate)
  
  Specified by:
  
  noneMatch in interface Stream<K>
- onClose
  
  public final MapStream<K,V> onClose(Runnable closeHandler)
  
  Specified by:
  
  onClose in interface BaseStream<K,V>
  
  Specified by:
  
  onClose in interface MapStream<K,V>
- parallel
  
  public final MapStream<K,V> parallel()
  
  Specified by:
  
  parallel in interface BaseStream<K,V>
  
  Specified by:
  
  parallel in interface MapStream<K,V>
- peek
  
  public final MapStream<K,V> peek(Consumer<? super Map.Entry<K,V>> action)
  
  Specified by:
  
  peek in interface MapStream<K,V>
  
  Specified by:
  
  peek in interface Stream<K>
- reduce
  
  public final Optional<Map.Entry<K,V>> reduce(BinaryOperator<Map.Entry<K,V>> accumulator)
  
  Specified by:
  
  reduce in interface Stream<K>
- reduce
  
  public final Map.Entry<K,V> reduce(Map.Entry<K,V> identity, BinaryOperator<Map.Entry<K,V>> accumulator)
  
  Specified by:
  
  reduce in interface Stream<K>
- reduce
  
  public final <U> U reduce(U identity, BiFunction<U, ? super Map.Entry<K,V>, U> accumulator, BinaryOperator<U> combiner)
  
  Specified by:
  
  reduce in interface Stream<K>
- sequential
  
  public final MapStream<K,V> sequential()
  
  Specified by:
  
  sequential in interface BaseStream<K,V>
  
  Specified by:
  
  sequential in interface MapStream<K,V>
- skip
  
  public final MapStream<K,V> skip(long n)
  
  Specified by:
  
  skip in interface MapStream<K,V>
  
  Specified by:
  
  skip in interface Stream<K>
- sorted
  
  public final MapStream<K,V> sorted()
  
  Specified by:
  
  sorted in interface MapStream<K,V>
  
  Specified by:
  
  sorted in interface Stream<K>
- sorted
  
  public final MapStream<K,V> sorted(Comparator<? super Map.Entry<K,V>> comparator)
  
  Specified by:
  
  sorted in interface MapStream<K,V>
  
  Specified by:
  
  sorted in interface Stream<K>
- spliterator
  public final Spliterator<Map.Entry<K,V>> spliterator()
  
  Specified by:
  
  spliterator in interface BaseStream<K,V>
  
  See Also:
  
  BaseStream.spliterator()
- toArray
  
  public final Object[] toArray()
  
  Specified by:
  
  toArray in interface Stream<K>
- toArray
  
  public final <A> A[] toArray(IntFunction<A[]> generator)
  
  Specified by:
  
  toArray in interface Stream<K>
- unordered
  
  public final MapStream<K,V> unordered()
  
  Specified by:
  
  unordered in interface BaseStream<K,V>
  
  Specified by:
  
  unordered in interface MapStream<K,V>

Class DefaultMapStream<K,V>

UML Diagram for "org.tquadrat.foundation.stream.internal.DefaultMapStream"

Nested Class Summary

Nested classes/interfaces inherited from interface Stream

Field Summary

Constructor Summary

Method Summary

Methods inherited from class Object

Methods inherited from interface MapStream

Methods inherited from interface Stream

Field Details

m_Delegate

Constructor Details

DefaultMapStream

Method Details

allMatch

anyMatch

close

collect

collect

count

distinct

filter

findAny

findFirst

flatMap

flatMapToDouble

flatMapToInt

flatMapToLong

forEach

forEachOrdered

isParallel

iterator

limit

map

mapToDouble

mapToInt

mapToLong

max

min

noneMatch

onClose

parallel

peek

reduce

reduce

reduce

sequential

skip

sorted

sorted

spliterator

toArray

toArray

unordered