Class ExDoubleStream

java.lang.Object

net.dapete.exceptional.stream.ExDoubleStream

All Implemented Interfaces:

AutoCloseable, BaseStream<Double, DoubleStream>, DoubleStream

public class ExDoubleStream
extends Object
implements DoubleStream

A DoubleStream with additional functionality for functional interfaces that throw Exceptions.

Implements versions of all methods from DoubleStream that use functional interfaces, using their counterparts with Exceptions instead, e.g. exMap(ExDoubleUnaryOperator) in parallel to map(DoubleUnaryOperator).

If these functional interfaces throw a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Note that this exception will likely not be thrown when a method is called, but only when a terminal operation or a stateful intermediate operation is used on the stream (except if it is itself such an operation).

Nested Class Summary

Nested classes/interfaces inherited from interface DoubleStream

DoubleStream.Builder, DoubleStream.DoubleMapMultiConsumer

Method Summary

Modifier and Type	Method	Description
ExStream<Double>	boxed()
ExDoubleStream	distinct()
static ExDoubleStream	empty()	Returns an empty instance.
boolean	exAllMatch(ExDoublePredicate<?> predicate)	Equivalent of DoubleStream.allMatch(DoublePredicate).
boolean	exAnyMatch(ExDoublePredicate<?> predicate)	Equivalent of DoubleStream.anyMatch(DoublePredicate).
<R> R	exCollect(ExSupplier<R,?> supplier, ExObjDoubleConsumer<R,?> accumulator, ExBiConsumer<R,R,?> combiner)	Equivalent of DoubleStream.collect(Supplier, ObjDoubleConsumer, BiConsumer).
ExDoubleStream	exDropWhile(ExDoublePredicate<?> predicate)	Equivalent of DoubleStream.dropWhile(DoublePredicate).
ExDoubleStream	exFilter(ExDoublePredicate<?> predicate)	Equivalent of DoubleStream.filter(DoublePredicate).
ExDoubleStream	exFlatMap(ExDoubleFunction<? extends DoubleStream, ?> mapper)	Equivalent of DoubleStream.flatMap(DoubleFunction).
void	exForEach(ExDoubleConsumer<?> action)	Equivalent of DoubleStream.forEach(DoubleConsumer).
void	exForEachOrdered(ExDoubleConsumer<?> action)	Equivalent of DoubleStream.forEachOrdered(DoubleConsumer).
ExDoubleStream	exMap(ExDoubleUnaryOperator<?> mapper)	Equivalent of DoubleStream.map(DoubleUnaryOperator).
ExDoubleStream	exMapMulti(ExDoubleMapMultiConsumer<?> mapper)	Equivalent of DoubleStream.mapMulti(DoubleStream.DoubleMapMultiConsumer).
ExIntStream	exMapToInt(ExDoubleToIntFunction<?> mapper)	Equivalent of DoubleStream.mapToInt(DoubleToIntFunction).
ExLongStream	exMapToLong(ExDoubleToLongFunction<?> mapper)	Equivalent of DoubleStream.mapToLong(DoubleToLongFunction).
<U> ExStream<U>	exMapToObj(ExDoubleFunction<? extends U, ?> mapper)	Equivalent of DoubleStream.mapToObj(DoubleFunction).
boolean	exNoneMatch(ExDoublePredicate<?> predicate)	Equivalent of DoubleStream.noneMatch(DoublePredicate).
ExDoubleStream	exPeek(ExDoubleConsumer<?> action)	Equivalent of DoubleStream.peek(DoubleConsumer).
Double	exReduce(double identity, ExDoubleBinaryOperator<?> op)	Equivalent of DoubleStream.reduce(double, DoubleBinaryOperator).
OptionalDouble	exReduce(ExDoubleBinaryOperator<?> op)	Equivalent of DoubleStream.reduce(DoubleBinaryOperator).
ExDoubleStream	exTakeWhile(ExDoublePredicate<?> predicate)	Equivalent of DoubleStream.takeWhile(DoublePredicate).
ExDoubleStream	filter(DoublePredicate predicate)
ExDoubleStream	flatMap(DoubleFunction<? extends DoubleStream> mapper)
ExDoubleStream	limit(long maxSize)
ExDoubleStream	map(DoubleUnaryOperator mapper)
ExIntStream	mapToInt(DoubleToIntFunction mapper)
ExLongStream	mapToLong(DoubleToLongFunction mapper)
<U> ExStream<U>	mapToObj(DoubleFunction<? extends U> mapper)
static ExDoubleStream	of(double t)	Returns an instance containing a single element.
static ExDoubleStream	of(double... values)	Returns an instance whose elements are the specified values.
static ExDoubleStream	of(DoubleStream stream)	Create an instance from an existing DoubleStream.
ExDoubleStream	onClose(Runnable closeHandler)
ExDoubleStream	parallel()
ExDoubleStream	peek(DoubleConsumer action)
ExDoubleStream	sequential()
ExDoubleStream	skip(long n)
ExDoubleStream	sorted()
ExDoubleStream	unordered()

Methods inherited from class Object

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

Methods inherited from interface BaseStream

close, isParallel

Methods inherited from interface DoubleStream

allMatch, anyMatch, average, collect, count, dropWhile, findAny, findFirst, forEach, forEachOrdered, iterator, mapMulti, max, min, noneMatch, reduce, reduce, spliterator, sum, summaryStatistics, takeWhile, toArray

Method Details

of

public static ExDoubleStream of(DoubleStream stream)

Create an instance from an existing DoubleStream.

Parameters:

stream - existing stream

Returns:

instance from an existing DoubleStream

empty

public static ExDoubleStream empty()

Returns an empty instance.

Returns:

an empty instance

of

public static ExDoubleStream of(double t)

Returns an instance containing a single element.

Parameters:

t - the single element

Returns:

an instance containing a single element

of

public static ExDoubleStream of(double... values)

Returns an instance whose elements are the specified values.

Parameters:

values - the elements of the new stream

Returns:

the new stream

mapToObj

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

Specified by:

mapToObj in interface DoubleStream

boxed

public ExStream<Double> boxed()

Specified by:

boxed in interface DoubleStream

filter

public ExDoubleStream filter(DoublePredicate predicate)

Specified by:

filter in interface DoubleStream

map

public ExDoubleStream map(DoubleUnaryOperator mapper)

Specified by:

map in interface DoubleStream

flatMap

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

Specified by:

flatMap in interface DoubleStream

distinct

public ExDoubleStream distinct()

Specified by:

distinct in interface DoubleStream

sorted

public ExDoubleStream sorted()

Specified by:

sorted in interface DoubleStream

peek

public ExDoubleStream peek(DoubleConsumer action)

Specified by:

peek in interface DoubleStream

limit

public ExDoubleStream limit(long maxSize)

Specified by:

limit in interface DoubleStream

skip

public ExDoubleStream skip(long n)

Specified by:

skip in interface DoubleStream

sequential

public ExDoubleStream sequential()

Specified by:

sequential in interface BaseStream<Double, DoubleStream>

Specified by:

sequential in interface DoubleStream

parallel

public ExDoubleStream parallel()

Specified by:

parallel in interface BaseStream<Double, DoubleStream>

Specified by:

parallel in interface DoubleStream

unordered

public ExDoubleStream unordered()

Specified by:

unordered in interface BaseStream<Double, DoubleStream>

onClose

public ExDoubleStream onClose(Runnable closeHandler)

Specified by:

onClose in interface BaseStream<Double, DoubleStream>

mapToInt

public ExIntStream mapToInt(DoubleToIntFunction mapper)

Specified by:

mapToInt in interface DoubleStream

mapToLong

public ExLongStream mapToLong(DoubleToLongFunction mapper)

Specified by:

mapToLong in interface DoubleStream

exFilter

public ExDoubleStream exFilter(ExDoublePredicate<?> predicate)

Equivalent of DoubleStream.filter(DoublePredicate).

If predicate throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Note that this exception will likely not be thrown when a method is called, but only when a terminal operation or a stateful intermediate operation is used on the stream.

Parameters:

predicate - see DoubleStream.filter(DoublePredicate)

Returns:

see DoubleStream.filter(DoublePredicate)

exMap

public ExDoubleStream exMap(ExDoubleUnaryOperator<?> mapper)

Equivalent of DoubleStream.map(DoubleUnaryOperator).

If mapper throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Note that this exception will likely not be thrown when a method is called, but only when a terminal operation or a stateful intermediate operation is used on the stream.

Parameters:

mapper - see DoubleStream.map(DoubleUnaryOperator)

Returns:

see DoubleStream.map(DoubleUnaryOperator)

exMapToObj

public <U> ExStream<U> exMapToObj(ExDoubleFunction<? extends U, ?> mapper)

Equivalent of DoubleStream.mapToObj(DoubleFunction).

If mapper throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Note that this exception will likely not be thrown when a method is called, but only when a terminal operation or a stateful intermediate operation is used on the stream.

Type Parameters:

U - the element type of the new stream

Parameters:

mapper - see DoubleStream.mapToObj(DoubleFunction)

Returns:

see DoubleStream.mapToObj(DoubleFunction)

exMapToInt

public ExIntStream exMapToInt(ExDoubleToIntFunction<?> mapper)

Equivalent of DoubleStream.mapToInt(DoubleToIntFunction).

If mapper throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Note that this exception will likely not be thrown when a method is called, but only when a terminal operation or a stateful intermediate operation is used on the stream.

Parameters:

mapper - see DoubleStream.mapToInt(DoubleToIntFunction)

Returns:

see DoubleStream.mapToInt(DoubleToIntFunction)

exMapToLong

public ExLongStream exMapToLong(ExDoubleToLongFunction<?> mapper)

Equivalent of DoubleStream.mapToLong(DoubleToLongFunction).

If mapper throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Note that this exception will likely not be thrown when a method is called, but only when a terminal operation or a stateful intermediate operation is used on the stream.

Parameters:

mapper - see DoubleStream.mapToLong(DoubleToLongFunction)

Returns:

see DoubleStream.mapToLong(DoubleToLongFunction)

exFlatMap

public ExDoubleStream exFlatMap(ExDoubleFunction<? extends DoubleStream, ?> mapper)

Equivalent of DoubleStream.flatMap(DoubleFunction).

If mapper throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Note that this exception will likely not be thrown when a method is called, but only when a terminal operation or a stateful intermediate operation is used on the stream.

Parameters:

mapper - see DoubleStream.flatMap(DoubleFunction)

Returns:

see DoubleStream.flatMap(DoubleFunction)

exMapMulti

public ExDoubleStream exMapMulti(ExDoubleMapMultiConsumer<?> mapper)

Equivalent of DoubleStream.mapMulti(DoubleStream.DoubleMapMultiConsumer).

If mapper throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Note that this exception will likely not be thrown when a method is called, but only when a terminal operation or a stateful intermediate operation is used on the stream.

Parameters:

mapper - see DoubleStream.mapMulti(DoubleStream.DoubleMapMultiConsumer)

Returns:

see DoubleStream.mapMulti(DoubleStream.DoubleMapMultiConsumer)

exPeek

public ExDoubleStream exPeek(ExDoubleConsumer<?> action)

Equivalent of DoubleStream.peek(DoubleConsumer).

If action throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Parameters:

action - see DoubleStream.peek(DoubleConsumer)

Returns:

see DoubleStream.peek(DoubleConsumer)

exTakeWhile

public ExDoubleStream exTakeWhile(ExDoublePredicate<?> predicate)

Equivalent of DoubleStream.takeWhile(DoublePredicate).

If predicate throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Parameters:

predicate - see DoubleStream.takeWhile(DoublePredicate)

Returns:

see DoubleStream.takeWhile(DoublePredicate)

exDropWhile

public ExDoubleStream exDropWhile(ExDoublePredicate<?> predicate)

Equivalent of DoubleStream.dropWhile(DoublePredicate).

If predicate throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Parameters:

predicate - see DoubleStream.dropWhile(DoublePredicate)

Returns:

see DoubleStream.dropWhile(DoublePredicate)

exForEach

public void exForEach(ExDoubleConsumer<?> action)

Equivalent of DoubleStream.forEach(DoubleConsumer).

If action throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Parameters:

action - see DoubleStream.forEach(DoubleConsumer)

exForEachOrdered

public void exForEachOrdered(ExDoubleConsumer<?> action)

Equivalent of DoubleStream.forEachOrdered(DoubleConsumer).

If action throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Parameters:

action - see DoubleStream.forEachOrdered(DoubleConsumer)

exReduce

public Double exReduce(double identity,
 ExDoubleBinaryOperator<?> op)

Equivalent of DoubleStream.reduce(double, DoubleBinaryOperator).

If action throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Parameters:

identity - see DoubleStream.reduce(double, DoubleBinaryOperator)

op - see DoubleStream.reduce(double, DoubleBinaryOperator)

Returns:

see DoubleStream.reduce(double, DoubleBinaryOperator)

exReduce

public OptionalDouble exReduce(ExDoubleBinaryOperator<?> op)

Equivalent of DoubleStream.reduce(DoubleBinaryOperator).

If action throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Parameters:

op - see DoubleStream.reduce(DoubleBinaryOperator)

Returns:

see DoubleStream.reduce(DoubleBinaryOperator)

exCollect

public <R> R exCollect(ExSupplier<R,?> supplier,
 ExObjDoubleConsumer<R,?> accumulator,
 ExBiConsumer<R,R,?> combiner)

Equivalent of DoubleStream.collect(Supplier, ObjDoubleConsumer, BiConsumer).

If supplier, accumulator or combiner throw a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Type Parameters:

R - the type of the mutable result container

Parameters:

supplier - see DoubleStream.collect(Supplier, ObjDoubleConsumer, BiConsumer)

accumulator - see DoubleStream.collect(Supplier, ObjDoubleConsumer, BiConsumer)

combiner - see DoubleStream.collect(Supplier, ObjDoubleConsumer, BiConsumer)

Returns:

see DoubleStream.collect(Supplier, ObjDoubleConsumer, BiConsumer)

exAnyMatch

public boolean exAnyMatch(ExDoublePredicate<?> predicate)

Equivalent of DoubleStream.anyMatch(DoublePredicate).

If predicate throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Parameters:

predicate - see DoubleStream.anyMatch(DoublePredicate)

Returns:

see DoubleStream.anyMatch(DoublePredicate)

exAllMatch

public boolean exAllMatch(ExDoublePredicate<?> predicate)

Equivalent of DoubleStream.allMatch(DoublePredicate).

If predicate throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Parameters:

predicate - see DoubleStream.allMatch(DoublePredicate)

Returns:

see DoubleStream.allMatch(DoublePredicate)

exNoneMatch

public boolean exNoneMatch(ExDoublePredicate<?> predicate)

Equivalent of DoubleStream.noneMatch(DoublePredicate).

If predicate throws a checked exception, a ExException will be thrown instead. This will have the original exception as its cause.

Parameters:

predicate - see DoubleStream.noneMatch(DoublePredicate)

Returns:

see DoubleStream.noneMatch(DoublePredicate)