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. map(Class, 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
<E extends Exception> boolean	allMatch(Class<E> exceptionClass, ExDoublePredicate<? extends E> predicate)	Equivalent of DoubleStream.allMatch(DoublePredicate).
<E extends Exception> boolean	anyMatch(Class<E> exceptionClass, ExDoublePredicate<? extends E> predicate)	Equivalent of DoubleStream.anyMatch(DoublePredicate).
ExStream<Double>	boxed()
<R, E extends Exception> R	collect(Class<E> exceptionClass, ExSupplier<R, ? extends E> supplier, ExObjDoubleConsumer<R, ? extends E> accumulator, ExBiConsumer<R, R, ? extends E> combiner)	Equivalent of DoubleStream.collect(Supplier, ObjDoubleConsumer, BiConsumer).
ExDoubleStream	distinct()
<E extends Exception> ExDoubleStream	dropWhile(Class<E> exceptionClass, ExDoublePredicate<? extends E> predicate)	Equivalent of DoubleStream.dropWhile(DoublePredicate).
static ExDoubleStream	empty()	Returns an empty instance.
<E extends Exception> ExDoubleStream	filter(Class<E> exceptionClass, ExDoublePredicate<? extends E> predicate)	Equivalent of DoubleStream.filter(DoublePredicate).
ExDoubleStream	filter(DoublePredicate predicate)
<E extends Exception> ExDoubleStream	flatMap(Class<E> exceptionClass, ExDoubleFunction<? extends DoubleStream, ? extends E> mapper)	Equivalent of DoubleStream.flatMap(DoubleFunction).
ExDoubleStream	flatMap(DoubleFunction<? extends DoubleStream> mapper)
<E extends Exception> void	forEach(Class<E> exceptionClass, ExDoubleConsumer<? extends E> action)	Equivalent of DoubleStream.forEach(DoubleConsumer).
<E extends Exception> void	forEachOrdered(Class<E> exceptionClass, ExDoubleConsumer<? extends E> action)	Equivalent of DoubleStream.forEachOrdered(DoubleConsumer).
ExDoubleStream	limit(long maxSize)
<E extends Exception> ExDoubleStream	map(Class<E> exceptionClass, ExDoubleUnaryOperator<? extends E> mapper)	Equivalent of DoubleStream.map(DoubleUnaryOperator).
ExDoubleStream	map(DoubleUnaryOperator mapper)
<E extends Exception> ExDoubleStream	mapMulti(Class<E> exceptionClass, ExDoubleMapMultiConsumer<? extends E> mapper)	Equivalent of DoubleStream.mapMulti(DoubleStream.DoubleMapMultiConsumer).
<E extends Exception> ExIntStream	mapToInt(Class<E> exceptionClass, ExDoubleToIntFunction<? extends E> mapper)	Equivalent of DoubleStream.mapToInt(DoubleToIntFunction).
ExIntStream	mapToInt(DoubleToIntFunction mapper)
<E extends Exception> ExLongStream	mapToLong(Class<E> exceptionClass, ExDoubleToLongFunction<? extends E> mapper)	Equivalent of DoubleStream.mapToLong(DoubleToLongFunction).
ExLongStream	mapToLong(DoubleToLongFunction mapper)
<U, E extends Exception> ExStream<U>	mapToObj(Class<E> exceptionClass, ExDoubleFunction<? extends U, ? extends E> mapper)	Equivalent of DoubleStream.mapToObj(DoubleFunction).
<U> ExStream<U>	mapToObj(DoubleFunction<? extends U> mapper)
<E extends Exception> boolean	noneMatch(Class<E> exceptionClass, ExDoublePredicate<? extends E> predicate)	Equivalent of DoubleStream.noneMatch(DoublePredicate).
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()
<E extends Exception> ExDoubleStream	peek(Class<E> exceptionClass, ExDoubleConsumer<? extends E> action)	Equivalent of DoubleStream.peek(DoubleConsumer).
ExDoubleStream	peek(DoubleConsumer action)
<E extends Exception> double	reduce(Class<E> exceptionClass, double identity, ExDoubleBinaryOperator<? extends E> op)	Equivalent of DoubleStream.reduce(double, DoubleBinaryOperator).
<E extends Exception> OptionalDouble	reduce(Class<E> exceptionClass, ExDoubleBinaryOperator<? extends E> op)	Equivalent of DoubleStream.reduce(DoubleBinaryOperator).
ExDoubleStream	sequential()
ExDoubleStream	skip(long n)
ExDoubleStream	sorted()
<E extends Exception> ExDoubleStream	takeWhile(Class<E> exceptionClass, ExDoublePredicate<? extends E> predicate)	Equivalent of DoubleStream.takeWhile(DoublePredicate).
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

filter

public <E extends Exception> ExDoubleStream filter(Class<E> exceptionClass,
 ExDoublePredicate<? extends E> 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.

Type Parameters:

E - The exception type thrown by mapper

Parameters:

exceptionClass - The exception class for E

predicate - see DoubleStream.filter(DoublePredicate)

Returns:

see DoubleStream.filter(DoublePredicate)

map

public <E extends Exception> ExDoubleStream map(Class<E> exceptionClass,
 ExDoubleUnaryOperator<? extends E> 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.

Type Parameters:

E - The exception type thrown by mapper

Parameters:

exceptionClass - The exception class for E

mapper - see DoubleStream.map(DoubleUnaryOperator)

Returns:

see DoubleStream.map(DoubleUnaryOperator)

mapToObj

public <U, E extends Exception> ExStream<U> mapToObj(Class<E> exceptionClass,
 ExDoubleFunction<? extends U, ? extends E> 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

E - The exception type thrown by mapper

Parameters:

exceptionClass - The exception class for E

mapper - see DoubleStream.mapToObj(DoubleFunction)

Returns:

see DoubleStream.mapToObj(DoubleFunction)

mapToInt

public <E extends Exception> ExIntStream mapToInt(Class<E> exceptionClass,
 ExDoubleToIntFunction<? extends E> 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.

Type Parameters:

E - The exception type thrown by mapper

Parameters:

exceptionClass - The exception class for E

mapper - see DoubleStream.mapToInt(DoubleToIntFunction)

Returns:

see DoubleStream.mapToInt(DoubleToIntFunction)

mapToLong

public <E extends Exception> ExLongStream mapToLong(Class<E> exceptionClass,
 ExDoubleToLongFunction<? extends E> 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.

Type Parameters:

E - The exception type thrown by mapper

Parameters:

exceptionClass - The exception class for E

mapper - see DoubleStream.mapToLong(DoubleToLongFunction)

Returns:

see DoubleStream.mapToLong(DoubleToLongFunction)

flatMap

public <E extends Exception> ExDoubleStream flatMap(Class<E> exceptionClass,
 ExDoubleFunction<? extends DoubleStream, ? extends E> 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.

Type Parameters:

E - The exception type thrown by mapper

Parameters:

exceptionClass - The exception class for E

mapper - see DoubleStream.flatMap(DoubleFunction)

Returns:

see DoubleStream.flatMap(DoubleFunction)

mapMulti

public <E extends Exception> ExDoubleStream mapMulti(Class<E> exceptionClass,
 ExDoubleMapMultiConsumer<? extends E> 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.

Type Parameters:

E - The exception type thrown by mapper

Parameters:

exceptionClass - The exception class for E

mapper - see DoubleStream.mapMulti(DoubleStream.DoubleMapMultiConsumer)

Returns:

see DoubleStream.mapMulti(DoubleStream.DoubleMapMultiConsumer)

peek

public <E extends Exception> ExDoubleStream peek(Class<E> exceptionClass,
 ExDoubleConsumer<? extends E> 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.

Type Parameters:

E - The exception type thrown by action

Parameters:

exceptionClass - The exception class for E

action - see DoubleStream.peek(DoubleConsumer)

Returns:

see DoubleStream.peek(DoubleConsumer)

takeWhile

public <E extends Exception> ExDoubleStream takeWhile(Class<E> exceptionClass,
 ExDoublePredicate<? extends E> 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.

Type Parameters:

E - The exception type thrown by predicate

Parameters:

exceptionClass - The exception class for E

predicate - see DoubleStream.takeWhile(DoublePredicate)

Returns:

see DoubleStream.takeWhile(DoublePredicate)

dropWhile

public <E extends Exception> ExDoubleStream dropWhile(Class<E> exceptionClass,
 ExDoublePredicate<? extends E> 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.

Type Parameters:

E - The exception type thrown by predicate

Parameters:

exceptionClass - The exception class for E

predicate - see DoubleStream.dropWhile(DoublePredicate)

Returns:

see DoubleStream.dropWhile(DoublePredicate)

forEach

public <E extends Exception> void forEach(Class<E> exceptionClass,
 ExDoubleConsumer<? extends E> 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.

Type Parameters:

E - The exception type thrown by action

Parameters:

exceptionClass - The exception class for E

action - see DoubleStream.forEach(DoubleConsumer)

forEachOrdered

public <E extends Exception> void forEachOrdered(Class<E> exceptionClass,
 ExDoubleConsumer<? extends E> 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.

Type Parameters:

E - The exception type thrown by action

Parameters:

exceptionClass - The exception class for E

action - see DoubleStream.forEachOrdered(DoubleConsumer)

reduce

public <E extends Exception> double reduce(Class<E> exceptionClass,
 double identity,
 ExDoubleBinaryOperator<? extends E> 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.

Type Parameters:

E - The exception type thrown by op

Parameters:

exceptionClass - The exception class for E

identity - see DoubleStream.reduce(double, DoubleBinaryOperator)

op - see DoubleStream.reduce(double, DoubleBinaryOperator)

Returns:

see DoubleStream.reduce(double, DoubleBinaryOperator)

reduce

public <E extends Exception> OptionalDouble reduce(Class<E> exceptionClass,
 ExDoubleBinaryOperator<? extends E> 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.

Type Parameters:

E - The exception type thrown by op

Parameters:

exceptionClass - The exception class for E

op - see DoubleStream.reduce(DoubleBinaryOperator)

Returns:

see DoubleStream.reduce(DoubleBinaryOperator)

collect

public <R, E extends Exception> R collect(Class<E> exceptionClass,
 ExSupplier<R, ? extends E> supplier,
 ExObjDoubleConsumer<R, ? extends E> accumulator,
 ExBiConsumer<R, R, ? extends E> 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

E - The exception type thrown by supplier, accumulator or combiner

Parameters:

exceptionClass - The exception class for E

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)

anyMatch

public <E extends Exception> boolean anyMatch(Class<E> exceptionClass,
 ExDoublePredicate<? extends E> 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.

Type Parameters:

E - The exception type thrown by predicate

Parameters:

exceptionClass - The exception class for E

predicate - see DoubleStream.anyMatch(DoublePredicate)

Returns:

see DoubleStream.anyMatch(DoublePredicate)

allMatch

public <E extends Exception> boolean allMatch(Class<E> exceptionClass,
 ExDoublePredicate<? extends E> 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.

Type Parameters:

E - The exception type thrown by predicate

Parameters:

exceptionClass - The exception class for E

predicate - see DoubleStream.allMatch(DoublePredicate)

Returns:

see DoubleStream.allMatch(DoublePredicate)

noneMatch

public <E extends Exception> boolean noneMatch(Class<E> exceptionClass,
 ExDoublePredicate<? extends E> 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.

Type Parameters:

E - The exception type thrown by predicate

Parameters:

exceptionClass - The exception class for E

predicate - see DoubleStream.noneMatch(DoublePredicate)

Returns:

see DoubleStream.noneMatch(DoublePredicate)