Interface TStream<T>

All Superinterfaces:

AutoCloseable, TBaseStream<T, TStream<T>>

All Known Implementing Classes:

TArrayStreamImpl, TBoxedDoubleStream, TBoxedIntStream, TBoxedLongStream, TBufferedReaderLinesStream, TCloseHandlingStream, TDistinctStreamImpl, TDropWhileStream, TEmptyStreamImpl, TFilteringStreamImpl, TFlatMappingStreamImpl, TGenerateStream, TGenericConcatStream, TIterateStream, TLimitingStreamImpl, TMappingStreamImpl, TMappingToObjStreamImpl, TMappingToObjStreamImpl, TMappingToObjStreamImpl, TPeekingStreamImpl, TSimpleStreamImpl, TSingleStreamImpl, TSkippingStreamImpl, TSortedStreamImpl, TSpecializedConcatStream, TStreamOverSpliterator, TStreamOverSpliteratorSupplier, TTakeWhileStream, TWrappingStreamImpl

public interface TStream<T>
extends TBaseStream<T, TStream<T>>

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	TStream.Builder<T>

Method Summary

Modifier and Type	Method	Description
boolean	allMatch(Predicate<? super T> predicate)
boolean	anyMatch(Predicate<? super T> predicate)
static <T> TStream.Builder<T>	builder()
<R> R	collect(Supplier<R> supplier, BiConsumer<R, ? super T> accumulator, BiConsumer<R,R> combiner)
<R,A> R	collect(TCollector<? super T, A, R> collector)
static <T> TStream<T>	concat(TStream<? extends T> a, TStream<? extends T> b)
long	count()
TStream<T>	distinct()
TStream<T>	dropWhile(Predicate<? super T> predicate)
static <T> TStream<T>	empty()
TStream<T>	filter(Predicate<? super T> predicate)
Optional<T>	findAny()
Optional<T>	findFirst()
<R> TStream<R>	flatMap(Function<? super T, ? extends TStream<? extends R>> mapper)
TDoubleStream	flatMapToDouble(Function<? super T, ? extends TDoubleStream> mapper)
TIntStream	flatMapToInt(Function<? super T, ? extends TIntStream> mapper)
TLongStream	flatMapToLong(Function<? super T, ? extends TLongStream> mapper)
void	forEach(Consumer<? super T> action)
void	forEachOrdered(Consumer<? super T> action)
static <T> TStream<T>	generate(Supplier<T> s)
static <T> TStream<T>	iterate(T seed, Predicate<? super T> pr, UnaryOperator<T> f)
static <T> TStream<T>	iterate(T seed, UnaryOperator<T> f)
TStream<T>	limit(long maxSize)
<R> TStream<R>	map(Function<? super T, ? extends R> mapper)
default <R> TStream<R>	mapMulti(BiConsumer<? super T, ? super Consumer<R>> mapper)
default TDoubleStream	mapMultiToDouble(BiConsumer<? super T, ? super DoubleConsumer> mapper)
default TIntStream	mapMultiToInt(BiConsumer<? super T, ? super IntConsumer> mapper)
default TLongStream	mapMultiToLong(BiConsumer<? super T, ? super LongConsumer> mapper)
TDoubleStream	mapToDouble(ToDoubleFunction<? super T> mapper)
TIntStream	mapToInt(ToIntFunction<? super T> mapper)
TLongStream	mapToLong(ToLongFunction<? super T> mapper)
Optional<T>	max(Comparator<? super T> comparator)
Optional<T>	min(Comparator<? super T> comparator)
boolean	noneMatch(Predicate<? super T> predicate)
static <T> TStream<T>	of(T t)
static <T> TStream<T>	of(T... values)
TStream<T>	peek(Consumer<? super T> action)
Optional<T>	reduce(BinaryOperator<T> accumulator)
T	reduce(T identity, BinaryOperator<T> accumulator)
<U> U	reduce(U identity, BiFunction<U, ? super T, U> accumulator, BinaryOperator<U> combiner)
TStream<T>	skip(long n)
TStream<T>	sorted()
TStream<T>	sorted(Comparator<? super T> comparator)
TStream<T>	takeWhile(Predicate<? super T> predicate)
Object[]	toArray()
<A> A[]	toArray(IntFunction<A[]> generator)
default List<T>	toList()

Methods inherited from interface TBaseStream

close, isParallel, iterator, onClose, parallel, sequential, spliterator, unordered

Method Details

filter

TStream<T> filter(Predicate<? super T> predicate)

map

<R> TStream<R> map(Function<? super T, ? extends R> mapper)

mapToInt

TIntStream mapToInt(ToIntFunction<? super T> mapper)

mapToLong

TLongStream mapToLong(ToLongFunction<? super T> mapper)

mapToDouble

TDoubleStream mapToDouble(ToDoubleFunction<? super T> mapper)

flatMap

<R> TStream<R> flatMap(Function<? super T, ? extends TStream<? extends R>> mapper)

flatMapToInt

TIntStream flatMapToInt(Function<? super T, ? extends TIntStream> mapper)

flatMapToLong

TLongStream flatMapToLong(Function<? super T, ? extends TLongStream> mapper)

flatMapToDouble

TDoubleStream flatMapToDouble(Function<? super T, ? extends TDoubleStream> mapper)

mapMulti

default <R> TStream<R> mapMulti(BiConsumer<? super T, ? super Consumer<R>> mapper)

mapMultiToInt

default TIntStream mapMultiToInt(BiConsumer<? super T, ? super IntConsumer> mapper)

mapMultiToLong

default TLongStream mapMultiToLong(BiConsumer<? super T, ? super LongConsumer> mapper)

mapMultiToDouble

default TDoubleStream mapMultiToDouble(BiConsumer<? super T, ? super DoubleConsumer> mapper)

distinct

TStream<T> distinct()

sorted

TStream<T> sorted()

sorted

TStream<T> sorted(Comparator<? super T> comparator)

peek

TStream<T> peek(Consumer<? super T> action)

limit

TStream<T> limit(long maxSize)

takeWhile

TStream<T> takeWhile(Predicate<? super T> predicate)

dropWhile

TStream<T> dropWhile(Predicate<? super T> predicate)

skip

TStream<T> skip(long n)

forEach

void forEach(Consumer<? super T> action)

forEachOrdered

void forEachOrdered(Consumer<? super T> action)

toArray

Object[] toArray()

toArray

<A> A[] toArray(IntFunction<A[]> generator)

reduce

T reduce(T identity,
 BinaryOperator<T> accumulator)

reduce

Optional<T> reduce(BinaryOperator<T> accumulator)

reduce

<U> U reduce(U identity,
 BiFunction<U, ? super T, U> accumulator,
 BinaryOperator<U> combiner)

collect

<R> R collect(Supplier<R> supplier,
 BiConsumer<R, ? super T> accumulator,
 BiConsumer<R,R> combiner)

collect

<R,A> R collect(TCollector<? super T, A, R> collector)

min

Optional<T> min(Comparator<? super T> comparator)

max

Optional<T> max(Comparator<? super T> comparator)

count

long count()

anyMatch

boolean anyMatch(Predicate<? super T> predicate)

allMatch

boolean allMatch(Predicate<? super T> predicate)

noneMatch

boolean noneMatch(Predicate<? super T> predicate)

findFirst

Optional<T> findFirst()

findAny

Optional<T> findAny()

builder

static <T> TStream.Builder<T> builder()

empty

static <T> TStream<T> empty()

of

static <T> TStream<T> of(T t)

of

@SafeVarargs
static <T> TStream<T> of(T... values)

iterate

static <T> TStream<T> iterate(T seed,
 UnaryOperator<T> f)

iterate

static <T> TStream<T> iterate(T seed,
 Predicate<? super T> pr,
 UnaryOperator<T> f)

generate

static <T> TStream<T> generate(Supplier<T> s)

concat

static <T> TStream<T> concat(TStream<? extends T> a,
 TStream<? extends T> b)

toList

default List<T> toList()