Package org.apache.sis.internal.stream

Class DoubleStreamWrapper

java.lang.Object

org.apache.sis.internal.stream.BaseStreamWrapper<Double,DoubleStream>

org.apache.sis.internal.stream.DoubleStreamWrapper

All Implemented Interfaces:

AutoCloseable, BaseStream<Double,DoubleStream>, DoubleStream

Direct Known Subclasses:

PaginedDoubleStream

public abstract class DoubleStreamWrapper
extends BaseStreamWrapper<Double,DoubleStream>
implements DoubleStream

A stream which delegates all operations to another stream of floating point values. This is equivalent to StreamWrapper but specialized for double primitive type.

Since:

1.1

Version:

1.1

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.stream.DoubleStream

DoubleStream.Builder

Field Summary

Fields

Modifier and Type	Field	Description
private DoubleStream	source	The source of elements, or null if this DoubleStreamWrapper is no longer the active stream.

Fields inherited from class org.apache.sis.internal.stream.BaseStreamWrapper

toClose

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DoubleStreamWrapper(DoubleStream source)	Creates a new wrapper for the given stream.

Method Summary

Modifier and Type	Method	Description
boolean	allMatch(DoublePredicate predicate)	Returns whether all elements of this stream match the provided predicate.
boolean	anyMatch(DoublePredicate predicate)	Returns whether at least one element of this stream matches the provided predicate.
OptionalDouble	average()	Returns the average of elements of this stream.
Stream<Double>	boxed()	Returns the stream elements as Double elements.
<R> R	collect(Supplier<R> supplier, ObjDoubleConsumer<R> accumulator, BiConsumer<R,R> combiner)	Performs a mutable reduction on the elements of this stream.
long	count()	Returns the number of elements in this stream.
(package private) final DoubleStream	delegate()	Same as source() but marks this stream is inactive.
DoubleStream	distinct()	Returns a stream with distinct elements of this stream.
DoubleStream	filter(DoublePredicate predicate)	Returns a stream with elements of this stream that match the given predicate.
OptionalDouble	findAny()	Returns any element of this stream.
OptionalDouble	findFirst()	Returns the first element of this stream.
DoubleStream	flatMap(DoubleFunction<? extends DoubleStream> mapper)	Returns a stream with results of applying the given function to the elements of this stream.
void	forEach(DoubleConsumer action)	Performs an action for each element of this stream.
void	forEachOrdered(DoubleConsumer action)	Performs an action for each element of this stream in encounter order.
PrimitiveIterator.OfDouble	iterator()	Returns an iterator for the elements of this stream.
DoubleStream	limit(long maxSize)	Returns a stream with truncated at the given number of elements.
DoubleStream	map(DoubleUnaryOperator mapper)	Returns a stream with results of applying the given function to the elements of this stream.
IntStream	mapToInt(DoubleToIntFunction mapper)	Returns a stream with results of applying the given function to the elements of this stream.
LongStream	mapToLong(DoubleToLongFunction mapper)	Returns a stream with results of applying the given function to the elements of this stream.
<U> Stream<U>	mapToObj(DoubleFunction<? extends U> mapper)	Returns a stream with results of applying the given function to the elements of this stream.
OptionalDouble	max()	Returns the maximum element of this stream.
OptionalDouble	min()	Returns the minimum element of this stream.
boolean	noneMatch(DoublePredicate predicate)	Returns whether none element of this stream match the provided predicate.
DoubleStream	onClose(Runnable closeHandler)	Returns an equivalent stream with an additional close handler.
DoubleStream	parallel()	Returns an equivalent stream that is parallel.
DoubleStream	peek(DoubleConsumer action)	Returns a stream performing the specified action on each element when consumed.
double	reduce(double identity, DoubleBinaryOperator op)	Performs a reduction on the elements of this stream.
OptionalDouble	reduce(DoubleBinaryOperator op)	Performs a reduction on the elements of this stream.
DoubleStream	sequential()	Returns an equivalent stream that is sequential.
DoubleStream	skip(long n)	Returns a stream discarding the specified number of elements.
DoubleStream	sorted()	Returns a stream with elements of this stream sorted in ascending order.
(package private) final DoubleStream	source()	Verifies that this stream is still the active one, then returns the source of this stream.
Spliterator.OfDouble	spliterator()	Returns a spliterator for the elements of this stream.
double	sum()	Returns the sum of elements of this stream.
DoubleSummaryStatistics	summaryStatistics()	Returns statistics about elements of this stream.
double[]	toArray()	Returns all elements in an array.
DoubleStream	unordered()	Returns an equivalent stream that is unordered.
private DoubleStream	update(DoubleStream result)	Invoked after an intermediate operation for determining which stream is the active one.

Methods inherited from class org.apache.sis.internal.stream.BaseStreamWrapper

close, inactive, isParallel

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.stream.BaseStream

close, isParallel

Field Details

source

private DoubleStream source

The source of elements, or null if this DoubleStreamWrapper is no longer the active stream. This is initialized at creation time and set to null after it has been determined that all subsequent operations shall be done on a new stream instead of this stream.

Constructor Details

DoubleStreamWrapper

protected DoubleStreamWrapper(DoubleStream source)

Creates a new wrapper for the given stream.

Parameters:

source - the stream to wrap.

Method Details

source

final DoubleStream source()

Verifies that this stream is still the active one, then returns the source of this stream.

Specified by:

source in class BaseStreamWrapper<Double,DoubleStream>

Returns:

the stream containing actual data.

Throws:

IllegalStateException - if this stream is no longer the active stream on which to apply operations.

delegate

final DoubleStream delegate()

Same as source() but marks this stream is inactive. All subsequent operations must be done on the returned stream. This is used for map(…) and flatMap(…) operations.

Returns:

the stream containing actual data.

Throws:

IllegalStateException - if this stream is no longer the active stream on which to apply operations.

update

private DoubleStream update(DoubleStream result)

Invoked after an intermediate operation for determining which stream is the active one. If this stream is still active, then this method returns this. Otherwise the given stream is returned.

parallel

public DoubleStream parallel()

Returns an equivalent stream that is parallel.

Specified by:

parallel in interface BaseStream<Double,DoubleStream>

Specified by:

parallel in interface DoubleStream

sequential

public DoubleStream sequential()

Returns an equivalent stream that is sequential.

Specified by:

sequential in interface BaseStream<Double,DoubleStream>

Specified by:

sequential in interface DoubleStream

unordered

public DoubleStream unordered()

Returns an equivalent stream that is unordered.

Specified by:

unordered in interface BaseStream<Double,DoubleStream>

filter

public DoubleStream filter(DoublePredicate predicate)

Returns a stream with elements of this stream that match the given predicate.

Specified by:

filter in interface DoubleStream

map

public DoubleStream map(DoubleUnaryOperator mapper)

Returns a stream with results of applying the given function to the elements of this stream.

Specified by:

map in interface DoubleStream

mapToObj

public <U> Stream<U> mapToObj(DoubleFunction<? extends U> mapper)

Returns a stream with results of applying the given function to the elements of this stream.

Specified by:

mapToObj in interface DoubleStream

mapToInt

public IntStream mapToInt(DoubleToIntFunction mapper)

Returns a stream with results of applying the given function to the elements of this stream.

Specified by:

mapToInt in interface DoubleStream

mapToLong

public LongStream mapToLong(DoubleToLongFunction mapper)

Returns a stream with results of applying the given function to the elements of this stream.

Specified by:

mapToLong in interface DoubleStream

flatMap

public DoubleStream flatMap(DoubleFunction<? extends DoubleStream> mapper)

Returns a stream with results of applying the given function to the elements of this stream.

Specified by:

flatMap in interface DoubleStream

distinct

public DoubleStream distinct()

Returns a stream with distinct elements of this stream.

Specified by:

distinct in interface DoubleStream

sorted

public DoubleStream sorted()

Returns a stream with elements of this stream sorted in ascending order.

Specified by:

sorted in interface DoubleStream

peek

public DoubleStream peek(DoubleConsumer action)

Returns a stream performing the specified action on each element when consumed.

Specified by:

peek in interface DoubleStream

limit

public DoubleStream limit(long maxSize)

Returns a stream with truncated at the given number of elements.

Specified by:

limit in interface DoubleStream

skip

public DoubleStream skip(long n)

Returns a stream discarding the specified number of elements.

Specified by:

skip in interface DoubleStream

forEach

public void forEach(DoubleConsumer action)

Performs an action for each element of this stream.

Specified by:

forEach in interface DoubleStream

forEachOrdered

public void forEachOrdered(DoubleConsumer action)

Performs an action for each element of this stream in encounter order.

Specified by:

forEachOrdered in interface DoubleStream

reduce

public double reduce(double identity,
 DoubleBinaryOperator op)

Performs a reduction on the elements of this stream.

Specified by:

reduce in interface DoubleStream

reduce

public OptionalDouble reduce(DoubleBinaryOperator op)

Performs a reduction on the elements of this stream.

Specified by:

reduce in interface DoubleStream

collect

public <R> R collect(Supplier<R> supplier,
 ObjDoubleConsumer<R> accumulator,
 BiConsumer<R,R> combiner)

Performs a mutable reduction on the elements of this stream.

Specified by:

collect in interface DoubleStream

sum

public double sum()

Returns the sum of elements of this stream.

Specified by:

sum in interface DoubleStream

min

public OptionalDouble min()

Returns the minimum element of this stream.

Specified by:

min in interface DoubleStream

max

public OptionalDouble max()

Returns the maximum element of this stream.

Specified by:

max in interface DoubleStream

count

public long count()

Returns the number of elements in this stream.

Specified by:

count in interface DoubleStream

average

public OptionalDouble average()

Returns the average of elements of this stream.

Specified by:

average in interface DoubleStream

summaryStatistics

public DoubleSummaryStatistics summaryStatistics()

Returns statistics about elements of this stream.

Specified by:

summaryStatistics in interface DoubleStream

anyMatch

public boolean anyMatch(DoublePredicate predicate)

Returns whether at least one element of this stream matches the provided predicate.

Specified by:

anyMatch in interface DoubleStream

allMatch

public boolean allMatch(DoublePredicate predicate)

Returns whether all elements of this stream match the provided predicate.

Specified by:

allMatch in interface DoubleStream

noneMatch

public boolean noneMatch(DoublePredicate predicate)

Returns whether none element of this stream match the provided predicate.

Specified by:

noneMatch in interface DoubleStream

findFirst

public OptionalDouble findFirst()

Returns the first element of this stream.

Specified by:

findFirst in interface DoubleStream

findAny

public OptionalDouble findAny()

Returns any element of this stream.

Specified by:

findAny in interface DoubleStream

boxed

public Stream<Double> boxed()

Returns the stream elements as Double elements.

Specified by:

boxed in interface DoubleStream

iterator

public PrimitiveIterator.OfDouble iterator()

Returns an iterator for the elements of this stream.

Specified by:

iterator in interface BaseStream<Double,DoubleStream>

Specified by:

iterator in interface DoubleStream

spliterator

public Spliterator.OfDouble spliterator()

Returns a spliterator for the elements of this stream.

Specified by:

spliterator in interface BaseStream<Double,DoubleStream>

Specified by:

spliterator in interface DoubleStream

toArray

public double[] toArray()

Returns all elements in an array.

Specified by:

toArray in interface DoubleStream

onClose

public DoubleStream onClose(Runnable closeHandler)

Returns an equivalent stream with an additional close handler.

Specified by:

onClose in interface BaseStream<Double,DoubleStream>