T
- The type of objects in the streampublic class DelegatingStream<T> extends Object implements java.util.stream.Stream<T>
DelegatingStream
class defines a Stream
implementation
that delegate operations to another stream.java.util.stream.Stream.Builder<T>
Modifier and Type | Field and Description |
---|---|
protected java.util.stream.Stream<T> |
delegate
Holds the stream to delegate to.
|
Constructor and Description |
---|
DelegatingStream(java.util.stream.Stream<T> delegate)
Instantiates a new
DelegatingStream object. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
builder, concat, empty, generate, iterate, of, of
protected final java.util.stream.Stream<T> delegate
public DelegatingStream(java.util.stream.Stream<T> delegate)
DelegatingStream
object.delegate
- the stream to delegate toNullPointerException
- if delegate
is null
public Iterator<T> iterator()
iterator
in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
BaseStream.iterator()
public Spliterator<T> spliterator()
spliterator
in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
BaseStream.spliterator()
public boolean isParallel()
isParallel
in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
BaseStream.isParallel()
public java.util.stream.Stream<T> sequential()
sequential
in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
BaseStream.sequential()
public java.util.stream.Stream<T> parallel()
parallel
in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
BaseStream.parallel()
public java.util.stream.Stream<T> unordered()
unordered
in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
BaseStream.unordered()
public java.util.stream.Stream<T> onClose(Runnable closeHandler)
onClose
in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
BaseStream.onClose(java.lang.Runnable)
public void close()
close
in interface AutoCloseable
close
in interface java.util.stream.BaseStream<T,java.util.stream.Stream<T>>
BaseStream.close()
public java.util.stream.Stream<T> filter(java.util.function.Predicate<? super T> predicate)
filter
in interface java.util.stream.Stream<T>
Stream.filter(java.util.function.Predicate)
public <R> java.util.stream.Stream<R> map(java.util.function.Function<? super T,? extends R> mapper)
map
in interface java.util.stream.Stream<T>
Stream.map(java.util.function.Function)
public java.util.stream.IntStream mapToInt(java.util.function.ToIntFunction<? super T> mapper)
mapToInt
in interface java.util.stream.Stream<T>
Stream.mapToInt(java.util.function.ToIntFunction)
public java.util.stream.LongStream mapToLong(java.util.function.ToLongFunction<? super T> mapper)
mapToLong
in interface java.util.stream.Stream<T>
Stream.mapToLong(java.util.function.ToLongFunction)
public java.util.stream.DoubleStream mapToDouble(java.util.function.ToDoubleFunction<? super T> mapper)
mapToDouble
in interface java.util.stream.Stream<T>
Stream.mapToDouble(java.util.function.ToDoubleFunction)
public <R> java.util.stream.Stream<R> flatMap(java.util.function.Function<? super T,? extends java.util.stream.Stream<? extends R>> mapper)
flatMap
in interface java.util.stream.Stream<T>
Stream.flatMap(java.util.function.Function)
public java.util.stream.IntStream flatMapToInt(java.util.function.Function<? super T,? extends java.util.stream.IntStream> mapper)
flatMapToInt
in interface java.util.stream.Stream<T>
Stream.flatMapToInt(java.util.function.Function)
public java.util.stream.LongStream flatMapToLong(java.util.function.Function<? super T,? extends java.util.stream.LongStream> mapper)
flatMapToLong
in interface java.util.stream.Stream<T>
Stream.flatMapToLong(java.util.function.Function)
public java.util.stream.DoubleStream flatMapToDouble(java.util.function.Function<? super T,? extends java.util.stream.DoubleStream> mapper)
flatMapToDouble
in interface java.util.stream.Stream<T>
Stream.flatMapToDouble(java.util.function.Function)
public java.util.stream.Stream<T> distinct()
distinct
in interface java.util.stream.Stream<T>
Stream.distinct()
public java.util.stream.Stream<T> sorted()
sorted
in interface java.util.stream.Stream<T>
Stream.sorted()
public java.util.stream.Stream<T> sorted(Comparator<? super T> comparator)
sorted
in interface java.util.stream.Stream<T>
Stream.sorted(java.util.Comparator)
public java.util.stream.Stream<T> peek(java.util.function.Consumer<? super T> consumer)
peek
in interface java.util.stream.Stream<T>
Stream.peek(java.util.function.Consumer)
public java.util.stream.Stream<T> limit(long maxSize)
limit
in interface java.util.stream.Stream<T>
Stream.limit(long)
public java.util.stream.Stream<T> skip(long n)
skip
in interface java.util.stream.Stream<T>
Stream.skip(long)
public void forEach(java.util.function.Consumer<? super T> consumer)
forEach
in interface java.util.stream.Stream<T>
Stream.forEach(java.util.function.Consumer)
public void forEachOrdered(java.util.function.Consumer<? super T> action)
forEachOrdered
in interface java.util.stream.Stream<T>
Stream.forEachOrdered(java.util.function.Consumer)
public Object[] toArray()
toArray
in interface java.util.stream.Stream<T>
Stream.toArray()
public <A> A[] toArray(java.util.function.IntFunction<A[]> generator)
toArray
in interface java.util.stream.Stream<T>
Stream.toArray(java.util.function.IntFunction)
public T reduce(T identity, java.util.function.BinaryOperator<T> reducer)
reduce
in interface java.util.stream.Stream<T>
Stream.reduce(java.lang.Object, java.util.function.BinaryOperator)
public Optional<T> reduce(java.util.function.BinaryOperator<T> combiner)
reduce
in interface java.util.stream.Stream<T>
Stream.reduce(java.util.function.BinaryOperator)
public <U> U reduce(U identity, java.util.function.BiFunction<U,? super T,U> accumulator, java.util.function.BinaryOperator<U> combiner)
reduce
in interface java.util.stream.Stream<T>
Stream.reduce(java.lang.Object, java.util.function.BiFunction, java.util.function.BinaryOperator)
public <R> R collect(java.util.function.Supplier<R> supplier, java.util.function.BiConsumer<R,? super T> accumulator, java.util.function.BiConsumer<R,R> combiner)
collect
in interface java.util.stream.Stream<T>
Stream.collect(java.util.function.Supplier, java.util.function.BiConsumer, java.util.function.BiConsumer)
public <R,A> R collect(java.util.stream.Collector<? super T,A,R> collector)
collect
in interface java.util.stream.Stream<T>
Stream.collect(java.util.stream.Collector)
public Optional<T> min(Comparator<? super T> comparator)
min
in interface java.util.stream.Stream<T>
Stream.min(java.util.Comparator)
public Optional<T> max(Comparator<? super T> comparator)
max
in interface java.util.stream.Stream<T>
Stream.max(java.util.Comparator)
public long count()
count
in interface java.util.stream.Stream<T>
Stream.count()
public boolean anyMatch(java.util.function.Predicate<? super T> predicate)
anyMatch
in interface java.util.stream.Stream<T>
Stream.anyMatch(java.util.function.Predicate)
public boolean allMatch(java.util.function.Predicate<? super T> predicate)
allMatch
in interface java.util.stream.Stream<T>
Stream.allMatch(java.util.function.Predicate)
public boolean noneMatch(java.util.function.Predicate<? super T> predicate)
noneMatch
in interface java.util.stream.Stream<T>
Stream.noneMatch(java.util.function.Predicate)
public Optional<T> findFirst()
findFirst
in interface java.util.stream.Stream<T>
Stream.findFirst()
public Optional<T> findAny()
findAny
in interface java.util.stream.Stream<T>
Stream.findAny()
Copyright (C) 2015-2017 The Helenus Driver Project Authors.