Class LongStreamEx
- All Implemented Interfaces:
AutoCloseable
,BaseStream<Long,
,LongStream> LongStream
LongStream
implementation with additional functionality-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic interface
A helper interface to build a new stream by emitting elements and creating new emitters in a chain.Nested classes/interfaces inherited from interface java.util.stream.LongStream
LongStream.Builder, LongStream.LongMapMultiConsumer
-
Field Summary
Fields inherited from class one.util.streamex.BaseStreamEx
CONSUMED_MESSAGE, context, spliterator
-
Constructor Summary
ConstructorsConstructorDescriptionLongStreamEx
(Spliterator.OfLong spliterator, StreamContext context) LongStreamEx
(LongStream stream, StreamContext context) -
Method Summary
Modifier and TypeMethodDescriptionboolean
allMatch
(LongPredicate predicate) boolean
anyMatch
(LongPredicate predicate) append
(long... values) Returns a newLongStreamEx
which is a concatenation of this stream and the stream containing supplied valuesappend
(LongStream other) Creates a lazily concatenated stream whose elements are all the elements of this stream followed by all the elements of the other stream.atLeast
(long value) Returns a stream consisting of the elements of this stream that greater than or equal to the specified value.atMost
(long value) Returns a stream consisting of the elements of this stream that less than or equal to the specified value.average()
boxed()
<U> U
chain
(Function<? super LongStreamEx, U> mapper) Applies the supplied function to this stream and returns the result of the function.<R> R
collect
(Supplier<R> supplier, ObjLongConsumer<R> accumulator, BiConsumer<R, R> combiner) <A,
R> R collect
(LongCollector<A, R> collector) Performs a mutable reduction operation on the elements of this stream using anLongCollector
which encapsulates the supplier, accumulator and merger functions making easier to reuse collection strategies.static LongStreamEx
constant
(long value, long length) Returns a sequential unorderedLongStreamEx
of given length which elements are equal to supplied value.long
count()
long
count
(LongPredicate predicate) Counts the number of elements in the stream that satisfy the predicate.(package private) LongStream
(package private) LongStreamEx
delegate
(Spliterator.OfLong spliterator) distinct()
dropWhile
(LongPredicate predicate) Returns a stream consisting of all elements from this stream starting from the first element which does not match the given predicate.static LongStreamEx
empty()
Returns an empty sequentialLongStreamEx
.filter
(LongPredicate predicate) findAny()
findAny
(LongPredicate predicate) Returns anOptionalLong
describing some element of the stream, which matches given predicate, or an emptyOptionalLong
if there's no matching element.findFirst
(LongPredicate predicate) Returns anOptionalLong
describing the first element of this stream, which matches given predicate, or an emptyOptionalLong
if there's no matching element.flatMap
(LongFunction<? extends LongStream> mapper) flatMapToDouble
(LongFunction<? extends DoubleStream> mapper) Returns aDoubleStreamEx
consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.flatMapToInt
(LongFunction<? extends IntStream> mapper) Returns anIntStreamEx
consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.<R> StreamEx<R>
flatMapToObj
(LongFunction<? extends Stream<R>> mapper) Returns aStreamEx
consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.long
foldLeft
(long seed, LongBinaryOperator accumulator) Folds the elements of this stream using the provided seed object and accumulation function, going left to right.foldLeft
(LongBinaryOperator accumulator) Folds the elements of this stream using the provided accumulation function, going left to right.void
forEach
(LongConsumer action) void
forEachOrdered
(LongConsumer action) static LongStreamEx
Returns an infinite sequential unordered stream where each element is generated by the providedLongSupplier
.greater
(long value) Returns a stream consisting of the elements of this stream that strictly greater than the specified value.boolean
has
(long value) Returns true if this stream contains the specified valueindexOf
(long value) Returns anOptionalLong
describing the zero-based index of the first element of this stream, which equals to the given value, or an emptyOptionalLong
if there's no matching element.indexOf
(LongPredicate predicate) Returns anOptionalLong
describing the zero-based index of the first element of this stream, which matches given predicate, or an emptyOptionalLong
if there's no matching element.intersperse
(int delimiter) Returns a new stream containing all the elements of the original stream interspersed with given delimiter.static LongStreamEx
iterate
(long seed, LongPredicate predicate, LongUnaryOperator f) Returns a sequential orderedLongStreamEx
produced by iterative application of a function to an initial element, conditioned on satisfying the supplied predicate.static LongStreamEx
iterate
(long seed, LongUnaryOperator f) Returns an infinite sequential orderedLongStreamEx
produced by iterative application of a functionf
to an initial elementseed
, producing a stream consisting ofseed
,f(seed)
,f(f(seed))
, etc.iterator()
joining
(CharSequence delimiter) Returns aString
which is the concatenation of the results of callingString.valueOf(long)
on each element of this stream, separated by the specified delimiter, in encounter order.joining
(CharSequence delimiter, CharSequence prefix, CharSequence suffix) Returns aString
which is the concatenation of the results of callingString.valueOf(long)
on each element of this stream, separated by the specified delimiter, with the specified prefix and suffix in encounter order.less
(long value) Returns a stream consisting of the elements of this stream that strictly less than the specified value.limit
(long maxSize) static LongStreamEx
longs()
Returns a sequential orderedLongStreamEx
from 0 (inclusive) toLong.MAX_VALUE
(exclusive) by an incremental step of1
.map
(LongUnaryOperator mapper) mapFirst
(LongUnaryOperator mapper) Returns a stream where the first element is the replaced with the result of applying the given function while the other elements are left intact.mapLast
(LongUnaryOperator mapper) Returns a stream where the last element is the replaced with the result of applying the given function while the other elements are left intact.mapToDouble
(LongToDoubleFunction mapper) <K,
V> EntryStream<K, V> mapToEntry
(LongFunction<? extends K> keyMapper, LongFunction<? extends V> valueMapper) Returns anEntryStream
consisting of theMap.Entry
objects which keys and values are results of applying the given functions to the elements of this stream.mapToInt
(LongToIntFunction mapper) <U> StreamEx<U>
mapToObj
(LongFunction<? extends U> mapper) max()
max
(Comparator<Long> comparator) Returns the maximum element of this stream according to the providedComparator
.<V extends Comparable<? super V>>
OptionalLongmaxBy
(LongFunction<V> keyExtractor) Returns the maximum element of this stream according to the provided key extractor function.maxByDouble
(LongToDoubleFunction keyExtractor) Returns the maximum element of this stream according to the provided key extractor function.maxByInt
(LongToIntFunction keyExtractor) Returns the maximum element of this stream according to the provided key extractor function.maxByLong
(LongUnaryOperator keyExtractor) Returns the maximum element of this stream according to the provided key extractor function.min()
min
(Comparator<Long> comparator) Returns the minimum element of this stream according to the providedComparator
.<V extends Comparable<? super V>>
OptionalLongminBy
(LongFunction<V> keyExtractor) Returns the minimum element of this stream according to the provided key extractor function.minByDouble
(LongToDoubleFunction keyExtractor) Returns the minimum element of this stream according to the provided key extractor function.minByInt
(LongToIntFunction keyExtractor) Returns the minimum element of this stream according to the provided key extractor function.minByLong
(LongUnaryOperator keyExtractor) Returns the minimum element of this stream according to the provided key extractor function.boolean
noneMatch
(LongPredicate predicate) static LongStreamEx
of
(long element) Returns a sequentialLongStreamEx
containing a single element.static LongStreamEx
of
(long... elements) Returns a sequential orderedLongStreamEx
whose elements are the specified values.static LongStreamEx
of
(long[] array, int startInclusive, int endExclusive) Returns a sequentialLongStreamEx
with the specified range of the specified array as its source.static LongStreamEx
Returns a sequential orderedLongStreamEx
whose elements are the unboxed elements of supplied array.static LongStreamEx
of
(LongBuffer buf) Returns a sequential orderedLongStreamEx
whose elements are the values in the suppliedLongBuffer
.static LongStreamEx
of
(Collection<Long> collection) Returns a sequential orderedLongStreamEx
whose elements are the unboxed elements of supplied collection.static LongStreamEx
of
(OptionalLong optional) Returns a sequentialLongStreamEx
containing anOptionalLong
value, if present, otherwise returns an emptyLongStreamEx
.static LongStreamEx
of
(PrimitiveIterator.OfLong iterator) Returns a sequential, orderedLongStreamEx
created from givenPrimitiveIterator.OfLong
.static LongStreamEx
Returns an effectively unlimited stream of pseudorandomlong
values produced by givenRandom
object.static LongStreamEx
Returns a stream producing the givenstreamSize
number of pseudorandomlong
values.static LongStreamEx
Returns an effectively unlimited stream of pseudorandomlong
values, each conforming to the given origin (inclusive) and bound (exclusive).static LongStreamEx
Returns a stream producing the givenstreamSize
number of pseudorandomlong
values, each conforming to the given origin (inclusive) and bound (exclusive).static LongStreamEx
of
(Spliterator.OfLong spliterator) Returns a sequentialLongStreamEx
created from givenSpliterator.OfLong
.static LongStreamEx
of
(LongStream stream) Returns aLongStreamEx
object which wraps givenLongStream
.pairMap
(LongBinaryOperator mapper) Returns a stream consisting of the results of applying the given function to the every adjacent pair of elements of this stream.parallel()
parallel
(ForkJoinPool fjp) Returns an equivalent stream that is parallel and bound to the suppliedForkJoinPool
.peek
(LongConsumer action) peekFirst
(LongConsumer action) Returns a stream consisting of the elements of this stream, additionally performing the provided action on the first stream element when it's consumed from the resulting stream.peekLast
(LongConsumer action) Returns a stream consisting of the elements of this stream, additionally performing the provided action on the last stream element when it's consumed from the resulting stream.Returns a stream containing cumulative results of applying the accumulation function going left to right.prepend
(long... values) Returns a newLongStreamEx
which is a concatenation of the stream containing supplied values and this streamprepend
(LongStream other) Creates a lazily concatenated stream whose elements are all the elements of the other stream followed by all the elements of this stream.static LongStreamEx
produce
(Predicate<LongConsumer> producer) Return an ordered stream produced by consecutive calls of the supplied producer until it returns false.static LongStreamEx
range
(long endExclusive) Returns a sequential orderedLongStreamEx
from 0 (inclusive) toendExclusive
(exclusive) by an incremental step of1
.static LongStreamEx
range
(long startInclusive, long endExclusive) Returns a sequential orderedLongStreamEx
fromstartInclusive
(inclusive) toendExclusive
(exclusive) by an incremental step of1
.static LongStreamEx
range
(long startInclusive, long endExclusive, long step) Returns a sequential orderedLongStreamEx
fromstartInclusive
(inclusive) toendExclusive
(exclusive) by the specified incremental step.static LongStreamEx
rangeClosed
(long startInclusive, long endInclusive) Returns a sequential orderedLongStreamEx
fromstartInclusive
(inclusive) toendInclusive
(inclusive) by an incremental step of1
.static LongStreamEx
rangeClosed
(long startInclusive, long endInclusive, long step) Returns a sequential orderedLongStreamEx
fromstartInclusive
(inclusive) toendInclusive
(inclusive) by the specified incremental step.long
reduce
(long identity, LongBinaryOperator op) remove
(LongPredicate predicate) Returns a stream consisting of the elements of this stream that don't match the given predicate.Returns a stream consisting of the elements of this stream in reverse sorted order.long[]
scanLeft
(long seed, LongBinaryOperator accumulator) Produces an array containing cumulative results of applying the accumulation function going left to right using given seed value.long[]
scanLeft
(LongBinaryOperator accumulator) Produces an array containing cumulative results of applying the accumulation function going left to right.private static LongStreamEx
seq
(LongStream stream) skip
(long n) sorted()
sorted
(Comparator<Long> comparator) Returns a stream consisting of the elements of this stream sorted according to the given comparator.<V extends Comparable<? super V>>
LongStreamExsortedBy
(LongFunction<V> keyExtractor) Returns a stream consisting of the elements of this stream, sorted according to the natural order of the keys extracted by provided function.sortedByDouble
(LongToDoubleFunction keyExtractor) Returns a stream consisting of the elements of this stream, sorted according to the double values extracted by provided function.sortedByInt
(LongToIntFunction keyExtractor) Returns a stream consisting of the elements of this stream, sorted according to the int values extracted by provided function.sortedByLong
(LongUnaryOperator keyExtractor) Returns a stream consisting of the elements of this stream, sorted according to the long values extracted by provided function.long
sum()
takeWhile
(LongPredicate predicate) Returns a stream consisting of all elements from this stream until the first element which does not match the given predicate is found.takeWhileInclusive
(LongPredicate predicate) Returns a stream consisting of all elements from this stream until the first element which does not match the given predicate is found (including the first mismatching element).long[]
toArray()
without
(long value) Returns a stream consisting of the elements of this stream that don't equal to the given value.without
(long... values) Returns a stream consisting of the elements of this stream that don't equal to any of the supplied values.static LongStreamEx
zip
(long[] first, long[] second, LongBinaryOperator mapper) Returns a sequentialLongStreamEx
containing the results of applying the given function to the corresponding pairs of values in given two arrays.Methods inherited from class one.util.streamex.BaseStreamEx
close, isParallel, spliterator, stream
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
Methods inherited from interface java.util.stream.LongStream
mapMulti, spliterator
-
Constructor Details
-
LongStreamEx
LongStreamEx(LongStream stream, StreamContext context) -
LongStreamEx
LongStreamEx(Spliterator.OfLong spliterator, StreamContext context)
-
-
Method Details
-
createStream
LongStream createStream()- Specified by:
createStream
in classBaseStreamEx<Long,
LongStream, Spliterator.OfLong, LongStreamEx>
-
seq
-
delegate
-
unordered
- Specified by:
unordered
in interfaceBaseStream<Long,
LongStream> - Overrides:
unordered
in classBaseStreamEx<Long,
LongStream, Spliterator.OfLong, LongStreamEx>
-
onClose
- Specified by:
onClose
in interfaceBaseStream<Long,
LongStream> - Overrides:
onClose
in classBaseStreamEx<Long,
LongStream, Spliterator.OfLong, LongStreamEx>
-
filter
- Specified by:
filter
in interfaceLongStream
-
remove
Returns a stream consisting of the elements of this stream that don't match the given predicate.This is an intermediate operation.
- Parameters:
predicate
- a non-interfering, stateless predicate to apply to each element to determine if it should be excluded- Returns:
- the new stream
-
has
public boolean has(long value) Returns true if this stream contains the specified valueThis is a short-circuiting terminal operation.
- Parameters:
value
- the value too look for in the stream- Returns:
- true if this stream contains the specified value
- See Also:
-
without
Returns a stream consisting of the elements of this stream that don't equal to the given value.This is an intermediate operation.
- Parameters:
value
- the value to remove from the stream.- Returns:
- the new stream
- Since:
- 0.2.2
- See Also:
-
without
Returns a stream consisting of the elements of this stream that don't equal to any of the supplied values.This is an intermediate operation. May return itself if no values were supplied.
Current implementation scans the supplied values linearly for every stream element.
If the
values
array is changed between calling this method and finishing the stream traversal, then the result of the stream traversal is undefined: changes may or may not be taken into account.- Parameters:
values
- the values to remove from the stream.- Returns:
- the new stream
- Since:
- 0.5.5
- See Also:
-
greater
Returns a stream consisting of the elements of this stream that strictly greater than the specified value.This is an intermediate operation.
- Parameters:
value
- a value to compare to- Returns:
- the new stream
- Since:
- 0.2.3
-
atLeast
Returns a stream consisting of the elements of this stream that greater than or equal to the specified value.This is an intermediate operation.
- Parameters:
value
- a value to compare to- Returns:
- the new stream
- Since:
- 0.2.3
-
less
Returns a stream consisting of the elements of this stream that strictly less than the specified value.This is an intermediate operation.
- Parameters:
value
- a value to compare to- Returns:
- the new stream
- Since:
- 0.2.3
-
atMost
Returns a stream consisting of the elements of this stream that less than or equal to the specified value.This is an intermediate operation.
- Parameters:
value
- a value to compare to- Returns:
- the new stream
- Since:
- 0.2.3
-
map
- Specified by:
map
in interfaceLongStream
-
mapFirst
Returns a stream where the first element is the replaced with the result of applying the given function while the other elements are left intact.This is a quasi-intermediate operation.
- Parameters:
mapper
- a non-interfering , stateless function to apply to the first element- Returns:
- the new stream
- Since:
- 0.4.1
-
mapLast
Returns a stream where the last element is the replaced with the result of applying the given function while the other elements are left intact.This is a quasi-intermediate operation.
The mapper function is called at most once. It could be not called at all if the stream is empty or there is short-circuiting operation downstream.
- Parameters:
mapper
- a non-interfering , stateless function to apply to the last element- Returns:
- the new stream
- Since:
- 0.4.1
-
mapToObj
- Specified by:
mapToObj
in interfaceLongStream
-
mapToInt
- Specified by:
mapToInt
in interfaceLongStream
-
mapToDouble
- Specified by:
mapToDouble
in interfaceLongStream
-
mapToEntry
public <K,V> EntryStream<K,V> mapToEntry(LongFunction<? extends K> keyMapper, LongFunction<? extends V> valueMapper) Returns anEntryStream
consisting of theMap.Entry
objects which keys and values are results of applying the given functions to the elements of this stream.This is an intermediate operation.
- Type Parameters:
K
- TheEntry
key typeV
- TheEntry
value type- Parameters:
keyMapper
- a non-interfering, stateless function to apply to each elementvalueMapper
- a non-interfering, stateless function to apply to each element- Returns:
- the new stream
- Since:
- 0.3.1
-
flatMap
- Specified by:
flatMap
in interfaceLongStream
-
flatMapToInt
Returns anIntStreamEx
consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element. Each mapped stream is closed after its contents have been placed into this stream. (If a mapped stream isnull
an empty stream is used, instead.)This is an intermediate operation.
- Parameters:
mapper
- a non-interfering, stateless function to apply to each element which produces anIntStream
of new values- Returns:
- the new stream
- Since:
- 0.3.0
-
flatMapToDouble
Returns aDoubleStreamEx
consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element. Each mapped stream is closed after its contents have been placed into this stream. (If a mapped stream isnull
an empty stream is used, instead.)This is an intermediate operation.
- Parameters:
mapper
- a non-interfering, stateless function to apply to each element which produces anDoubleStream
of new values- Returns:
- the new stream
- Since:
- 0.3.0
-
flatMapToObj
Returns aStreamEx
consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element. Each mapped stream is closed after its contents have been placed into this stream. (If a mapped stream isnull
an empty stream is used, instead.)This is an intermediate operation.
- Type Parameters:
R
- The element type of the new stream- Parameters:
mapper
- a non-interfering, stateless function to apply to each element which produces aStream
of new values- Returns:
- the new stream
- Since:
- 0.3.0
-
intersperse
Returns a new stream containing all the elements of the original stream interspersed with given delimiter.For example,
LongStreamEx.of(1, 2, 3).intersperse(4)
will yield a stream containing five elements: 1, 4, 2, 4, 3.This is an intermediate operation.
- Parameters:
delimiter
- a delimiter to be inserted between each pair of elements- Returns:
- the new stream
- Since:
- 0.6.6
-
distinct
- Specified by:
distinct
in interfaceLongStream
-
sorted
- Specified by:
sorted
in interfaceLongStream
-
sorted
Returns a stream consisting of the elements of this stream sorted according to the given comparator. Stream elements are boxed before passing to the comparator.For ordered streams, the sort is stable. For unordered streams, no stability guarantees are made.
This is a stateful intermediate operation.
- Parameters:
comparator
- a non-interfering , statelessComparator
to be used to compare stream elements- Returns:
- the new stream
-
reverseSorted
Returns a stream consisting of the elements of this stream in reverse sorted order.This is a stateful intermediate operation.
- Returns:
- the new stream
- Since:
- 0.0.8
-
sortedBy
Returns a stream consisting of the elements of this stream, sorted according to the natural order of the keys extracted by provided function.For ordered streams, the sort is stable. For unordered streams, no stability guarantees are made.
This is a stateful intermediate operation.
- Type Parameters:
V
- the type of theComparable
sort key- Parameters:
keyExtractor
- a non-interfering , stateless function to be used to extract sorting keys- Returns:
- the new stream
-
sortedByInt
Returns a stream consisting of the elements of this stream, sorted according to the int values extracted by provided function.For ordered streams, the sort is stable. For unordered streams, no stability guarantees are made.
This is a stateful intermediate operation.
- Parameters:
keyExtractor
- a non-interfering , stateless function to be used to extract sorting keys- Returns:
- the new stream
-
sortedByLong
Returns a stream consisting of the elements of this stream, sorted according to the long values extracted by provided function.For ordered streams, the sort is stable. For unordered streams, no stability guarantees are made.
This is a stateful intermediate operation.
- Parameters:
keyExtractor
- a non-interfering , stateless function to be used to extract sorting keys- Returns:
- the new stream
-
sortedByDouble
Returns a stream consisting of the elements of this stream, sorted according to the double values extracted by provided function.For ordered streams, the sort is stable. For unordered streams, no stability guarantees are made.
This is a stateful intermediate operation.
- Parameters:
keyExtractor
- a non-interfering , stateless function to be used to extract sorting keys- Returns:
- the new stream
-
peek
- Specified by:
peek
in interfaceLongStream
-
peekFirst
Returns a stream consisting of the elements of this stream, additionally performing the provided action on the first stream element when it's consumed from the resulting stream.This is an intermediate operation.
The action is called at most once. For parallel stream pipelines, it's not guaranteed in which thread it will be executed, so if it modifies shared state, it is responsible for providing the required synchronization.
Note that the action might not be called at all if the first element is not consumed from the input (for example, if there's short-circuiting operation downstream which stopped the stream before the first element).
This method exists mainly to support debugging.
- Parameters:
action
- a non-interfering action to perform on the first stream element as it is consumed from the stream- Returns:
- the new stream
- Since:
- 0.6.0
-
peekLast
Returns a stream consisting of the elements of this stream, additionally performing the provided action on the last stream element when it's consumed from the resulting stream.This is an intermediate operation.
The action is called at most once. For parallel stream pipelines, it's not guaranteed in which thread it will be executed, so if it modifies shared state, it is responsible for providing the required synchronization.
Note that the action might not be called at all if the last element is not consumed from the input (for example, if there's short-circuiting operation downstream).
This method exists mainly to support debugging.
- Parameters:
action
- a non-interfering action to perform on the first stream element as it is consumed from the stream- Returns:
- the new stream
- Since:
- 0.6.0
-
limit
- Specified by:
limit
in interfaceLongStream
-
skip
- Specified by:
skip
in interfaceLongStream
-
forEach
- Specified by:
forEach
in interfaceLongStream
-
forEachOrdered
- Specified by:
forEachOrdered
in interfaceLongStream
-
toArray
public long[] toArray()- Specified by:
toArray
in interfaceLongStream
-
reduce
- Specified by:
reduce
in interfaceLongStream
-
reduce
- Specified by:
reduce
in interfaceLongStream
-
foldLeft
Folds the elements of this stream using the provided accumulation function, going left to right. This is equivalent to:boolean foundAny = false; long result = 0; for (long element : this stream) { if (!foundAny) { foundAny = true; result = element; } else result = accumulator.apply(result, element); } return foundAny ? OptionalLong.of(result) : OptionalLong.empty();
This is a terminal operation.
This method cannot take all the advantages of parallel streams as it must process elements strictly left to right. If your accumulator function is associative, consider using
reduce(LongBinaryOperator)
method.For parallel stream it's not guaranteed that accumulator will always be executed in the same thread.
- Parameters:
accumulator
- a non-interfering , stateless function for incorporating an additional element into a result- Returns:
- the result of the folding
- Since:
- 0.4.0
- See Also:
-
foldLeft
Folds the elements of this stream using the provided seed object and accumulation function, going left to right. This is equivalent to:long result = seed; for (long element : this stream) result = accumulator.apply(result, element) return result;
This is a terminal operation.
This method cannot take all the advantages of parallel streams as it must process elements strictly left to right. If your accumulator function is associative, consider using
reduce(long, LongBinaryOperator)
method.For parallel stream it's not guaranteed that accumulator will always be executed in the same thread.
- Parameters:
seed
- the starting valueaccumulator
- a non-interfering , stateless function for incorporating an additional element into a result- Returns:
- the result of the folding
- Since:
- 0.4.0
- See Also:
-
scanLeft
Produces an array containing cumulative results of applying the accumulation function going left to right.This is a terminal operation.
For parallel stream it's not guaranteed that accumulator will always be executed in the same thread.
This method cannot take all the advantages of parallel streams as it must process elements strictly left to right.
- Parameters:
accumulator
- a non-interfering , stateless function for incorporating an additional element into a result- Returns:
- the array where the first element is the first element of this stream and every successor element is the result of applying accumulator function to the previous array element and the corresponding stream element. The resulting array has the same length as this stream.
- Since:
- 0.5.1
- See Also:
-
scanLeft
Produces an array containing cumulative results of applying the accumulation function going left to right using given seed value.This is a terminal operation.
For parallel stream it's not guaranteed that accumulator will always be executed in the same thread.
This method cannot take all the advantages of parallel streams as it must process elements strictly left to right.
- Parameters:
seed
- the starting valueaccumulator
- a non-interfering , stateless function for incorporating an additional element into a result- Returns:
- the array where the first element is the seed and every successor element is the result of applying accumulator function to the previous array element and the corresponding stream element. The resulting array is one element longer than this stream.
- Since:
- 0.5.1
- See Also:
-
collect
public <R> R collect(Supplier<R> supplier, ObjLongConsumer<R> accumulator, BiConsumer<R, R> combiner) - Specified by:
collect
in interfaceLongStream
- See Also:
-
collect
Performs a mutable reduction operation on the elements of this stream using anLongCollector
which encapsulates the supplier, accumulator and merger functions making easier to reuse collection strategies.Like
reduce(long, LongBinaryOperator)
,collect
operations can be parallelized without requiring additional synchronization.This is a terminal operation.
- Type Parameters:
A
- the intermediate accumulation type of theLongCollector
R
- type of the result- Parameters:
collector
- theLongCollector
describing the reduction- Returns:
- the result of the reduction
- Since:
- 0.3.0
- See Also:
-
sum
public long sum()- Specified by:
sum
in interfaceLongStream
-
min
- Specified by:
min
in interfaceLongStream
-
min
Returns the minimum element of this stream according to the providedComparator
.This is a terminal operation.
- Parameters:
comparator
- a non-interfering, statelessComparator
to compare elements of this stream- Returns:
- an
OptionalLong
describing the minimum element of this stream, or an emptyOptionalLong
if the stream is empty - Since:
- 0.1.2
-
minBy
Returns the minimum element of this stream according to the provided key extractor function.This is a terminal operation.
- Type Parameters:
V
- the type of theComparable
sort key- Parameters:
keyExtractor
- a non-interfering, stateless function- Returns:
- an
OptionalLong
describing the first element of this stream for which the lowest value was returned by key extractor, or an emptyOptionalLong
if the stream is empty - Since:
- 0.1.2
-
minByInt
Returns the minimum element of this stream according to the provided key extractor function.This is a terminal operation.
- Parameters:
keyExtractor
- a non-interfering, stateless function- Returns:
- an
OptionalLong
describing the first element of this stream for which the lowest value was returned by key extractor, or an emptyOptionalLong
if the stream is empty - Since:
- 0.1.2
-
minByLong
Returns the minimum element of this stream according to the provided key extractor function.This is a terminal operation.
- Parameters:
keyExtractor
- a non-interfering, stateless function- Returns:
- an
OptionalLong
describing the first element of this stream for which the lowest value was returned by key extractor, or an emptyOptionalLong
if the stream is empty - Since:
- 0.1.2
-
minByDouble
Returns the minimum element of this stream according to the provided key extractor function.This is a terminal operation.
- Parameters:
keyExtractor
- a non-interfering, stateless function- Returns:
- an
OptionalLong
describing the first element of this stream for which the lowest value was returned by key extractor, or an emptyOptionalLong
if the stream is empty - Since:
- 0.1.2
-
max
- Specified by:
max
in interfaceLongStream
-
max
Returns the maximum element of this stream according to the providedComparator
.This is a terminal operation.
- Parameters:
comparator
- a non-interfering, statelessComparator
to compare elements of this stream- Returns:
- an
OptionalLong
describing the maximum element of this stream, or an emptyOptionalLong
if the stream is empty
-
maxBy
Returns the maximum element of this stream according to the provided key extractor function.This is a terminal operation.
- Type Parameters:
V
- the type of theComparable
sort key- Parameters:
keyExtractor
- a non-interfering, stateless function- Returns:
- an
OptionalLong
describing the first element of this stream for which the highest value was returned by key extractor, or an emptyOptionalLong
if the stream is empty - Since:
- 0.1.2
-
maxByInt
Returns the maximum element of this stream according to the provided key extractor function.This is a terminal operation.
- Parameters:
keyExtractor
- a non-interfering, stateless function- Returns:
- an
OptionalLong
describing the first element of this stream for which the highest value was returned by key extractor, or an emptyOptionalLong
if the stream is empty - Since:
- 0.1.2
-
maxByLong
Returns the maximum element of this stream according to the provided key extractor function.This is a terminal operation.
- Parameters:
keyExtractor
- a non-interfering, stateless function- Returns:
- an
OptionalLong
describing the first element of this stream for which the highest value was returned by key extractor, or an emptyOptionalLong
if the stream is empty - Since:
- 0.1.2
-
maxByDouble
Returns the maximum element of this stream according to the provided key extractor function.This is a terminal operation.
- Parameters:
keyExtractor
- a non-interfering, stateless function- Returns:
- an
OptionalLong
describing the first element of this stream for which the highest value was returned by key extractor, or an emptyOptionalLong
if the stream is empty - Since:
- 0.1.2
-
count
public long count()- Specified by:
count
in interfaceLongStream
-
count
Counts the number of elements in the stream that satisfy the predicate.This is a terminal operation.
- Parameters:
predicate
- a non-interfering , stateless predicate to apply to stream elements. Only elements passing the predicate will be counted.- Returns:
- the count of elements in this stream satisfying the predicate.
-
average
- Specified by:
average
in interfaceLongStream
-
summaryStatistics
- Specified by:
summaryStatistics
in interfaceLongStream
-
anyMatch
- Specified by:
anyMatch
in interfaceLongStream
-
allMatch
- Specified by:
allMatch
in interfaceLongStream
-
noneMatch
- Specified by:
noneMatch
in interfaceLongStream
-
findFirst
- Specified by:
findFirst
in interfaceLongStream
-
findFirst
Returns anOptionalLong
describing the first element of this stream, which matches given predicate, or an emptyOptionalLong
if there's no matching element.This is a short-circuiting terminal operation.
- Parameters:
predicate
- a non-interfering , stateless predicate which returned value should match- Returns:
- an
OptionalLong
describing the first matching element of this stream, or an emptyOptionalLong
if there's no matching element - See Also:
-
findAny
- Specified by:
findAny
in interfaceLongStream
-
findAny
Returns anOptionalLong
describing some element of the stream, which matches given predicate, or an emptyOptionalLong
if there's no matching element.This is a short-circuiting terminal operation.
The behavior of this operation is explicitly nondeterministic; it is free to select any element in the stream. This is to allow for maximal performance in parallel operations; the cost is that multiple invocations on the same source may not return the same result. (If a stable result is desired, use
findFirst(LongPredicate)
instead.)- Parameters:
predicate
- a non-interfering , stateless predicate which returned value should match- Returns:
- an
OptionalLong
describing some matching element of this stream, or an emptyOptionalLong
if there's no matching element - See Also:
-
indexOf
Returns anOptionalLong
describing the zero-based index of the first element of this stream, which equals to the given value, or an emptyOptionalLong
if there's no matching element.This is a short-circuiting terminal operation.
- Parameters:
value
- a value to look for- Returns:
- an
OptionalLong
describing the index of the first matching element of this stream, or an emptyOptionalLong
if there's no matching element. - Since:
- 0.4.0
- See Also:
-
indexOf
Returns anOptionalLong
describing the zero-based index of the first element of this stream, which matches given predicate, or an emptyOptionalLong
if there's no matching element.This is a short-circuiting terminal operation.
- Parameters:
predicate
- a non-interfering , stateless predicate which returned value should match- Returns:
- an
OptionalLong
describing the index of the first matching element of this stream, or an emptyOptionalLong
if there's no matching element. - Since:
- 0.4.0
- See Also:
-
asDoubleStream
- Specified by:
asDoubleStream
in interfaceLongStream
-
boxed
- Specified by:
boxed
in interfaceLongStream
-
sequential
- Specified by:
sequential
in interfaceBaseStream<Long,
LongStream> - Specified by:
sequential
in interfaceLongStream
- Overrides:
sequential
in classBaseStreamEx<Long,
LongStream, Spliterator.OfLong, LongStreamEx>
-
parallel
Description copied from class:BaseStreamEx
If this stream was created using
BaseStreamEx.parallel(ForkJoinPool)
, the new stream forgets about supplied customForkJoinPool
and its terminal operation will be executed in common pool.- Specified by:
parallel
in interfaceBaseStream<Long,
LongStream> - Specified by:
parallel
in interfaceLongStream
- Overrides:
parallel
in classBaseStreamEx<Long,
LongStream, Spliterator.OfLong, LongStreamEx>
-
parallel
Description copied from class:BaseStreamEx
Returns an equivalent stream that is parallel and bound to the suppliedForkJoinPool
.This is an intermediate operation.
The terminal operation of this stream or any derived stream (except the streams created via
BaseStreamEx.parallel()
orBaseStreamEx.sequential()
methods) will be executed inside the suppliedForkJoinPool
. If current thread does not belong to that pool, it will wait till calculation finishes.- Overrides:
parallel
in classBaseStreamEx<Long,
LongStream, Spliterator.OfLong, LongStreamEx> - Parameters:
fjp
- aForkJoinPool
to submit the stream operation to.- Returns:
- a parallel stream bound to the supplied
ForkJoinPool
-
iterator
- Specified by:
iterator
in interfaceBaseStream<Long,
LongStream> - Specified by:
iterator
in interfaceLongStream
-
append
Returns a newLongStreamEx
which is a concatenation of this stream and the stream containing supplied valuesThis is a quasi-intermediate operation.
- Parameters:
values
- the values to append to the stream- Returns:
- the new stream
-
append
Creates a lazily concatenated stream whose elements are all the elements of this stream followed by all the elements of the other stream. The resulting stream is ordered if both of the input streams are ordered, and parallel if either of the input streams is parallel. When the resulting stream is closed, the close handlers for both input streams are invoked.- Parameters:
other
- the other stream- Returns:
- this stream appended by the other stream
- See Also:
-
prepend
Returns a newLongStreamEx
which is a concatenation of the stream containing supplied values and this streamThis is a quasi-intermediate operation.
- Parameters:
values
- the values to prepend to the stream- Returns:
- the new stream
-
prepend
Creates a lazily concatenated stream whose elements are all the elements of the other stream followed by all the elements of this stream. The resulting stream is ordered if both of the input streams are ordered, and parallel if either of the input streams is parallel. When the resulting stream is closed, the close handlers for both input streams are invoked.- Parameters:
other
- the other stream- Returns:
- this stream prepended by the other stream
- See Also:
-
pairMap
Returns a stream consisting of the results of applying the given function to the every adjacent pair of elements of this stream.This is a quasi-intermediate operation.
The output stream will contain one element less than this stream. If this stream contains zero or one element the output stream will be empty.
- Parameters:
mapper
- a non-interfering, stateless function to apply to each adjacent pair of this stream elements.- Returns:
- the new stream
- Since:
- 0.2.1
-
joining
Returns aString
which is the concatenation of the results of callingString.valueOf(long)
on each element of this stream, separated by the specified delimiter, in encounter order.This is a terminal operation.
- Parameters:
delimiter
- the delimiter to be used between each element- Returns:
- the result of concatenation. For empty input stream empty String is returned.
- Since:
- 0.3.1
-
joining
Returns aString
which is the concatenation of the results of callingString.valueOf(long)
on each element of this stream, separated by the specified delimiter, with the specified prefix and suffix in encounter order.This is a terminal operation.
- Parameters:
delimiter
- the delimiter to be used between each elementprefix
- the sequence of characters to be used at the beginning of the joined resultsuffix
- the sequence of characters to be used at the end of the joined result- Returns:
- the result of concatenation. For empty input stream
prefix + suffix
is returned. - Since:
- 0.3.1
-
takeWhile
Returns a stream consisting of all elements from this stream until the first element which does not match the given predicate is found.This is a short-circuiting stateful operation. It can be either intermediate or quasi-intermediate. When using with JDK 1.9 or higher it calls the corresponding JDK 1.9 implementation. When using with JDK 1.8 it uses own implementation.
While this operation is quite cheap for sequential stream, it can be quite expensive on parallel pipelines.
- Specified by:
takeWhile
in interfaceLongStream
- Parameters:
predicate
- a non-interfering, stateless predicate to apply to elements.- Returns:
- the new stream.
- Since:
- 0.3.6
- See Also:
-
takeWhileInclusive
Returns a stream consisting of all elements from this stream until the first element which does not match the given predicate is found (including the first mismatching element).This is a quasi-intermediate operation.
While this operation is quite cheap for sequential stream, it can be quite expensive on parallel pipelines.
- Parameters:
predicate
- a non-interfering, stateless predicate to apply to elements.- Returns:
- the new stream.
- Since:
- 0.5.5
- See Also:
-
dropWhile
Returns a stream consisting of all elements from this stream starting from the first element which does not match the given predicate. If the predicate is true for all stream elements, an empty stream is returned.This is a stateful operation. It can be either intermediate or quasi-intermediate. When using with JDK 1.9 or higher it calls the corresponding JDK 1.9 implementation. When using with JDK 1.8 it uses own implementation.
While this operation is quite cheap for sequential stream, it can be quite expensive on parallel pipelines.
- Specified by:
dropWhile
in interfaceLongStream
- Parameters:
predicate
- a non-interfering, stateless predicate to apply to elements.- Returns:
- the new stream.
- Since:
- 0.3.6
-
prefix
Returns a stream containing cumulative results of applying the accumulation function going left to right.This is a stateful quasi-intermediate operation.
This operation resembles
scanLeft(LongBinaryOperator)
, but unlikescanLeft
this operation is intermediate and accumulation function must be associative.This method cannot take all the advantages of parallel streams as it must process elements strictly left to right. Using an unordered source or removing the ordering constraint with
unordered()
may improve the parallel processing speed.- Parameters:
op
- an associative , non-interfering , stateless function for computing the next element based on the previous one- Returns:
- the new stream.
- Since:
- 0.6.1
- See Also:
-
chain
Description copied from class:BaseStreamEx
Applies the supplied function to this stream and returns the result of the function.This method can be used to add more functionality in the fluent style. For example, consider user-defined static method
batches(stream, n)
which breaks the stream into batches of given length. Normally you would writebatches(StreamEx.of(input).map(...), 10).filter(...)
. Using thechain()
method you can write in more fluent manner:StreamEx.of(input).map(...).chain(s -> batches(s, 10)).filter(...)
.You could even go further and define a method which returns a function like
<T> UnaryOperator<StreamEx<T>> batches(int n)
and use it like this:StreamEx.of(input).map(...).chain(batches(10)).filter(...)
.- Specified by:
chain
in classBaseStreamEx<Long,
LongStream, Spliterator.OfLong, LongStreamEx> - Type Parameters:
U
- the type of the function result.- Parameters:
mapper
- function to invoke.- Returns:
- the result of the function invocation.
-
empty
Returns an empty sequentialLongStreamEx
.- Returns:
- an empty sequential stream
-
of
Returns a sequentialLongStreamEx
containing a single element.- Parameters:
element
- the single element- Returns:
- a singleton sequential stream
-
of
Returns a sequential orderedLongStreamEx
whose elements are the specified values.- Parameters:
elements
- the elements of the new stream- Returns:
- the new stream
-
of
Returns a sequentialLongStreamEx
with the specified range of the specified array as its source.- Parameters:
array
- the array, assumed to be unmodified during usestartInclusive
- the first index to cover, inclusiveendExclusive
- index immediately past the last index to cover- Returns:
- an
LongStreamEx
for the array range - Throws:
ArrayIndexOutOfBoundsException
- ifstartInclusive
is negative,endExclusive
is less thanstartInclusive
, orendExclusive
is greater than the array size- Since:
- 0.1.1
- See Also:
-
of
Returns a sequential orderedLongStreamEx
whose elements are the unboxed elements of supplied array.- Parameters:
array
- the array to create the stream from.- Returns:
- the new stream
- Since:
- 0.5.0
- See Also:
-
of
Returns a sequential orderedLongStreamEx
whose elements are the values in the suppliedLongBuffer
.The resulting stream covers only a portion of
LongBuffer
content which starts with position (inclusive) and ends with limit (exclusive). Changes in position and limit after the stream creation don't affect the stream.The resulting stream does not change the internal
LongBuffer
state.- Parameters:
buf
- theLongBuffer
to create a stream from- Returns:
- the new stream
- Since:
- 0.6.2
-
of
Returns aLongStreamEx
object which wraps givenLongStream
.The supplied stream must not be consumed or closed when this method is called. No operation must be performed on the supplied stream after it's wrapped.
- Parameters:
stream
- original stream- Returns:
- the wrapped stream
- Since:
- 0.0.8
-
of
Returns a sequentialLongStreamEx
created from givenSpliterator.OfLong
.- Parameters:
spliterator
- a spliterator to create the stream from.- Returns:
- the new stream
- Since:
- 0.3.4
-
of
Returns a sequential, orderedLongStreamEx
created from givenPrimitiveIterator.OfLong
.This method is roughly equivalent to
LongStreamEx.of(Spliterators.spliteratorUnknownSize(iterator, ORDERED))
, but may show better performance for parallel processing.Use this method only if you cannot provide better Stream source.
- Parameters:
iterator
- an iterator to create the stream from.- Returns:
- the new stream
- Since:
- 0.5.1
-
of
Returns a sequentialLongStreamEx
containing anOptionalLong
value, if present, otherwise returns an emptyLongStreamEx
.- Parameters:
optional
- the optional to create a stream of- Returns:
- a stream with an
OptionalLong
value if present, otherwise an empty stream - Since:
- 0.1.1
-
of
Returns a sequential orderedLongStreamEx
whose elements are the unboxed elements of supplied collection.- Parameters:
collection
- the collection to create the stream from.- Returns:
- the new stream
- See Also:
-
of
Returns an effectively unlimited stream of pseudorandomlong
values produced by givenRandom
object.A pseudorandom
long
value is generated as if it's the result of calling the methodRandom.nextLong()
.- Parameters:
random
- aRandom
object to produce the stream from- Returns:
- a stream of pseudorandom
long
values - See Also:
-
of
Returns a stream producing the givenstreamSize
number of pseudorandomlong
values.A pseudorandom
long
value is generated as if it's the result of calling the methodRandom.nextLong()
- Parameters:
random
- aRandom
object to produce the stream fromstreamSize
- the number of values to generate- Returns:
- a stream of pseudorandom
long
values - See Also:
-
of
Returns an effectively unlimited stream of pseudorandomlong
values, each conforming to the given origin (inclusive) and bound (exclusive).- Parameters:
random
- aRandom
object to produce the stream fromrandomNumberOrigin
- the origin (inclusive) of each random valuerandomNumberBound
- the bound (exclusive) of each random value- Returns:
- a stream of pseudorandom
long
values - See Also:
-
of
public static LongStreamEx of(Random random, long streamSize, long randomNumberOrigin, long randomNumberBound) Returns a stream producing the givenstreamSize
number of pseudorandomlong
values, each conforming to the given origin (inclusive) and bound (exclusive).- Parameters:
random
- aRandom
object to produce the stream fromstreamSize
- the number of values to generaterandomNumberOrigin
- the origin (inclusive) of each random valuerandomNumberBound
- the bound (exclusive) of each random value- Returns:
- a stream of pseudorandom
long
values - See Also:
-
iterate
Returns an infinite sequential orderedLongStreamEx
produced by iterative application of a functionf
to an initial elementseed
, producing a stream consisting ofseed
,f(seed)
,f(f(seed))
, etc.The first element (position
0
) in theLongStreamEx
will be the providedseed
. Forn > 0
, the element at positionn
, will be the result of applying the functionf
to the element at positionn - 1
.- Parameters:
seed
- the initial elementf
- a function to be applied to to the previous element to produce a new element- Returns:
- A new sequential
LongStream
- See Also:
-
iterate
Returns a sequential orderedLongStreamEx
produced by iterative application of a function to an initial element, conditioned on satisfying the supplied predicate. The stream terminates as soon as the predicate function returns false.LongStreamEx.iterate
should produce the same sequence of elements as produced by the corresponding for-loop:for (long index=seed; predicate.test(index); index = f.apply(index)) { ... }
The resulting sequence may be empty if the predicate does not hold on the seed value. Otherwise the first element will be the supplied seed value, the next element (if present) will be the result of applying the function f to the seed value, and so on iteratively until the predicate indicates that the stream should terminate.
- Parameters:
seed
- the initial elementpredicate
- a predicate to apply to elements to determine when the stream must terminate.f
- a function to be applied to the previous element to produce a new element- Returns:
- a new sequential
LongStreamEx
- Since:
- 0.6.0
- See Also:
-
generate
Returns an infinite sequential unordered stream where each element is generated by the providedLongSupplier
. This is suitable for generating constant streams, streams of random elements, etc.- Parameters:
s
- theLongSupplier
for generated elements- Returns:
- a new infinite sequential unordered
LongStreamEx
- See Also:
-
produce
Return an ordered stream produced by consecutive calls of the supplied producer until it returns false.The producer function may call the passed consumer any number of times and return true if the producer should be called again or false otherwise. It's guaranteed that the producer will not be called anymore, once it returns false.
This method is particularly useful when producer changes the mutable object which should be left in known state after the full stream consumption. Note however that if a short-circuiting operation is used, then the final state of the mutable object cannot be guaranteed.
- Parameters:
producer
- a predicate which calls the passed consumer to emit stream element(s) and returns true if it producer should be applied again.- Returns:
- the new stream
- Since:
- 0.6.0
-
longs
Returns a sequential orderedLongStreamEx
from 0 (inclusive) toLong.MAX_VALUE
(exclusive) by an incremental step of1
.- Returns:
- a sequential
LongStreamEx
for the range oflong
elements - Since:
- 0.5.5
- See Also:
-
range
Returns a sequential orderedLongStreamEx
from 0 (inclusive) toendExclusive
(exclusive) by an incremental step of1
.- Parameters:
endExclusive
- the exclusive upper bound- Returns:
- a sequential
LongStreamEx
for the range ofint
elements - Since:
- 0.1.1
- See Also:
-
range
Returns a sequential orderedLongStreamEx
fromstartInclusive
(inclusive) toendExclusive
(exclusive) by an incremental step of1
.- Parameters:
startInclusive
- the (inclusive) initial valueendExclusive
- the exclusive upper bound- Returns:
- a sequential
LongStreamEx
for the range oflong
elements - See Also:
-
range
Returns a sequential orderedLongStreamEx
fromstartInclusive
(inclusive) toendExclusive
(exclusive) by the specified incremental step. The negative step values are also supported. In this case, thestartInclusive
should be greater thanendExclusive
.- Parameters:
startInclusive
- the (inclusive) initial valueendExclusive
- the exclusive upper (for positive step) or lower (for negative step) boundstep
- the non-zero value which designates the difference between the consecutive values of the resulting stream.- Returns:
- a sequential
LongStreamEx
for the range oflong
elements - Throws:
IllegalArgumentException
- if step is zero- Since:
- 0.4.0
- See Also:
-
rangeClosed
Returns a sequential orderedLongStreamEx
fromstartInclusive
(inclusive) toendInclusive
(inclusive) by an incremental step of1
.- Parameters:
startInclusive
- the (inclusive) initial valueendInclusive
- the inclusive upper bound- Returns:
- a sequential
LongStreamEx
for the range oflong
elements - See Also:
-
rangeClosed
Returns a sequential orderedLongStreamEx
fromstartInclusive
(inclusive) toendInclusive
(inclusive) by the specified incremental step. The negative step values are also supported. In this case, thestartInclusive
should be not less thanendInclusive
.Note that depending on the step value the
endInclusive
bound may still not be reached. For exampleLongStreamEx.rangeClosed(0, 5, 2)
will yield the stream of three numbers: 0L, 2L and 4L.- Parameters:
startInclusive
- the (inclusive) initial valueendInclusive
- the inclusive upper (for positive step) or lower (for negative step) boundstep
- the non-zero value which designates the difference between the consecutive values of the resulting stream.- Returns:
- a sequential
LongStreamEx
for the range oflong
elements; an empty stream if startInclusive is greater than endInclusive for positive step, or if startInclusive is less than endInclusive for negative step. - Throws:
IllegalArgumentException
- if step is zero- Since:
- 0.4.0
- See Also:
-
constant
Returns a sequential unorderedLongStreamEx
of given length which elements are equal to supplied value.- Parameters:
value
- the constant valuelength
- the length of the stream- Returns:
- a new
LongStreamEx
- Since:
- 0.1.2
-
zip
Returns a sequentialLongStreamEx
containing the results of applying the given function to the corresponding pairs of values in given two arrays.- Parameters:
first
- the first arraysecond
- the second arraymapper
- a non-interfering, stateless function to apply to each pair of the corresponding array elements.- Returns:
- a new
LongStreamEx
- Throws:
IllegalArgumentException
- if length of the arrays differs.- Since:
- 0.2.1
-