public class SackStream<T>
extends java.lang.Object
implements java.util.stream.Stream<T>
Constructor and Description |
---|
SackStream(java.util.Iterator esi) |
SackStream(java.util.Iterator esi,
boolean parallel) |
Modifier and Type | Method and Description |
---|---|
boolean |
allMatch(java.util.function.Predicate predicate) |
boolean |
anyMatch(java.util.function.Predicate predicate) |
void |
close() |
java.lang.Object |
collect(java.util.stream.Collector collector) |
java.lang.Object |
collect(java.util.function.Supplier supplier,
java.util.function.BiConsumer accumulator,
java.util.function.BiConsumer combiner) |
long |
count() |
java.util.stream.Stream |
distinct() |
java.util.stream.Stream<T> |
filter(java.util.function.Predicate predicate) |
java.util.Optional |
findAny() |
java.util.Optional |
findFirst() |
java.util.stream.Stream |
flatMap(java.util.function.Function mapper) |
java.util.stream.DoubleStream |
flatMapToDouble(java.util.function.Function mapper) |
java.util.stream.IntStream |
flatMapToInt(java.util.function.Function mapper) |
java.util.stream.LongStream |
flatMapToLong(java.util.function.Function mapper) |
void |
forEach(java.util.function.Consumer action) |
void |
forEachOrdered(java.util.function.Consumer action) |
boolean |
isParallel() |
java.util.Iterator |
iterator() |
java.util.stream.Stream |
limit(long maxSize) |
java.util.stream.Stream |
map(java.util.function.Function mapper) |
java.util.stream.DoubleStream |
mapToDouble(java.util.function.ToDoubleFunction mapper) |
java.util.stream.IntStream |
mapToInt(java.util.function.ToIntFunction mapper) |
java.util.stream.LongStream |
mapToLong(java.util.function.ToLongFunction mapper) |
java.util.Optional |
max(java.util.Comparator comparator) |
java.util.Optional |
min(java.util.Comparator comparator) |
boolean |
noneMatch(java.util.function.Predicate predicate) |
java.util.stream.Stream<T> |
of() |
java.util.stream.Stream<T> |
onClose(java.lang.Runnable closeHandler) |
java.util.stream.Stream<T> |
parallel() |
java.util.stream.Stream |
peek(java.util.function.Consumer action) |
java.util.Optional |
reduce(java.util.function.BinaryOperator accumulator) |
java.lang.Object |
reduce(java.lang.Object identity,
java.util.function.BiFunction accumulator,
java.util.function.BinaryOperator combiner) |
java.lang.Object |
reduce(java.lang.Object identity,
java.util.function.BinaryOperator accumulator) |
java.util.stream.Stream<T> |
sequential() |
void |
setParallel(boolean parallel) |
java.util.stream.Stream |
skip(long n) |
java.util.stream.Stream |
sorted() |
java.util.stream.Stream |
sorted(java.util.Comparator comparator) |
java.util.Spliterator |
spliterator() |
java.lang.Object[] |
toArray() |
java.lang.Object[] |
toArray(java.util.function.IntFunction generator) |
java.util.stream.Stream<T> |
unordered() |
public SackStream(java.util.Iterator esi)
public SackStream(java.util.Iterator esi, boolean parallel)
public java.util.stream.Stream<T> of()
public void setParallel(boolean parallel)
public java.util.stream.Stream<T> filter(java.util.function.Predicate predicate)
filter
in interface java.util.stream.Stream<T>
public java.util.stream.Stream map(java.util.function.Function mapper)
map
in interface java.util.stream.Stream<T>
public java.util.stream.IntStream mapToInt(java.util.function.ToIntFunction mapper)
mapToInt
in interface java.util.stream.Stream<T>
public java.util.stream.LongStream mapToLong(java.util.function.ToLongFunction mapper)
mapToLong
in interface java.util.stream.Stream<T>
public java.util.stream.DoubleStream mapToDouble(java.util.function.ToDoubleFunction mapper)
mapToDouble
in interface java.util.stream.Stream<T>
public java.util.stream.Stream flatMap(java.util.function.Function mapper)
flatMap
in interface java.util.stream.Stream<T>
public java.util.stream.IntStream flatMapToInt(java.util.function.Function mapper)
flatMapToInt
in interface java.util.stream.Stream<T>
public java.util.stream.LongStream flatMapToLong(java.util.function.Function mapper)
flatMapToLong
in interface java.util.stream.Stream<T>
public java.util.stream.DoubleStream flatMapToDouble(java.util.function.Function mapper)
flatMapToDouble
in interface java.util.stream.Stream<T>
public java.util.stream.Stream distinct()
distinct
in interface java.util.stream.Stream<T>
public java.util.stream.Stream sorted()
sorted
in interface java.util.stream.Stream<T>
public java.util.stream.Stream sorted(java.util.Comparator comparator)
sorted
in interface java.util.stream.Stream<T>
public java.util.stream.Stream peek(java.util.function.Consumer action)
peek
in interface java.util.stream.Stream<T>
public java.util.stream.Stream limit(long maxSize)
limit
in interface java.util.stream.Stream<T>
public java.util.stream.Stream skip(long n)
skip
in interface java.util.stream.Stream<T>
public void forEach(java.util.function.Consumer action)
forEach
in interface java.util.stream.Stream<T>
public void forEachOrdered(java.util.function.Consumer action)
forEachOrdered
in interface java.util.stream.Stream<T>
public java.lang.Object[] toArray()
toArray
in interface java.util.stream.Stream<T>
public java.lang.Object[] toArray(java.util.function.IntFunction generator)
toArray
in interface java.util.stream.Stream<T>
public java.lang.Object reduce(java.lang.Object identity, java.util.function.BinaryOperator accumulator)
reduce
in interface java.util.stream.Stream<T>
public java.util.Optional reduce(java.util.function.BinaryOperator accumulator)
reduce
in interface java.util.stream.Stream<T>
public java.lang.Object reduce(java.lang.Object identity, java.util.function.BiFunction accumulator, java.util.function.BinaryOperator combiner)
reduce
in interface java.util.stream.Stream<T>
public java.lang.Object collect(java.util.function.Supplier supplier, java.util.function.BiConsumer accumulator, java.util.function.BiConsumer combiner)
collect
in interface java.util.stream.Stream<T>
public java.lang.Object collect(java.util.stream.Collector collector)
collect
in interface java.util.stream.Stream<T>
public java.util.Optional min(java.util.Comparator comparator)
min
in interface java.util.stream.Stream<T>
public java.util.Optional max(java.util.Comparator comparator)
max
in interface java.util.stream.Stream<T>
public long count()
count
in interface java.util.stream.Stream<T>
public boolean anyMatch(java.util.function.Predicate predicate)
anyMatch
in interface java.util.stream.Stream<T>
public boolean allMatch(java.util.function.Predicate predicate)
allMatch
in interface java.util.stream.Stream<T>
public boolean noneMatch(java.util.function.Predicate predicate)
noneMatch
in interface java.util.stream.Stream<T>
public java.util.Optional findFirst()
findFirst
in interface java.util.stream.Stream<T>
public java.util.Optional findAny()
findAny
in interface java.util.stream.Stream<T>
public java.util.Iterator iterator()
public java.util.Spliterator spliterator()
public boolean isParallel()
public java.util.stream.Stream<T> sequential()
public java.util.stream.Stream<T> parallel()
public java.util.stream.Stream<T> unordered()
public java.util.stream.Stream<T> onClose(java.lang.Runnable closeHandler)