com.github.lokic.javaplus.stream

类 ExStream<T>

java.lang.Object

com.github.lokic.javaplus.stream.ExStream<T>

public class ExStream<T>
extends Object

方法概要

限定符和类型	方法和说明
ExStream<T>	cached()
ExStream<T>	distinctByKey(java.util.function.Function<? super T,?> keyExtractor)
ExStream<T>	dropWhile(java.util.function.Predicate<? super T> predicate)
ExStream<T>	filter(java.util.function.Predicate<? super T> predicate)
<R> ExStream<R>	flatMap(java.util.function.Function<? super T,? extends java.util.stream.Stream<? extends R>> mapper)
void	forEachWithIndex(java.util.function.BiConsumer<Integer,? super T> biConsumer)
<U,K,R> ExStream<R>	fullOuterJoin(java.util.stream.Stream<U> right, JoinOn<T,U,K,R> on)
<R> ExStream<R>	func(java.util.function.Function<java.util.stream.Stream<T>,java.util.stream.Stream<R>> function)
<U,K,R> ExStream<R>	innerJoin(java.util.stream.Stream<U> right, JoinOn<T,U,K,R> on)
<U,K,R> ExStream<R>	leftOuterJoin(java.util.stream.Stream<U> right, JoinOn<T,U,K,R> on)
<R> ExStream<R>	map(java.util.function.Function<? super T,? extends R> mapper)
<R> ExStream<R>	mapWithIndex(java.util.function.BiFunction<Integer,? super T,? extends R> biFunction)
<R> ExStream<R>	memoized(java.util.function.Function<? super T,? extends R> function)
static <T> ExStream<T>	of(Collection<T> collection)
static <T> ExStream<T>	of(JoinStream<T> joinStream)
static <T> ExStream<T>	of(java.util.stream.Stream<T> stream)
static <T> ExStream<T>	of(java.util.function.Supplier<java.util.stream.Stream<T>> streamProvider)
static <T> ExStream<T>	of(T... values)
<U,K,R> ExStream<R>	rightOuterJoin(java.util.stream.Stream<U> right, JoinOn<T,U,K,R> on)
java.util.stream.Stream<T>	stream()
ExStream<T>	takeWhile(java.util.function.Predicate<? super T> predicate)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

func

public <R> ExStream<R> func(java.util.function.Function<java.util.stream.Stream<T>,java.util.stream.Stream<R>> function)

filter

public ExStream<T> filter(java.util.function.Predicate<? super T> predicate)

map

public <R> ExStream<R> map(java.util.function.Function<? super T,? extends R> mapper)

flatMap

public <R> ExStream<R> flatMap(java.util.function.Function<? super T,? extends java.util.stream.Stream<? extends R>> mapper)

takeWhile

public ExStream<T> takeWhile(java.util.function.Predicate<? super T> predicate)

dropWhile

public ExStream<T> dropWhile(java.util.function.Predicate<? super T> predicate)

distinctByKey

public ExStream<T> distinctByKey(java.util.function.Function<? super T,?> keyExtractor)

mapWithIndex

public <R> ExStream<R> mapWithIndex(java.util.function.BiFunction<Integer,? super T,? extends R> biFunction)

forEachWithIndex

public void forEachWithIndex(java.util.function.BiConsumer<Integer,? super T> biConsumer)

memoized

public <R> ExStream<R> memoized(java.util.function.Function<? super T,? extends R> function)

innerJoin

public <U,K,R> ExStream<R> innerJoin(java.util.stream.Stream<U> right,
                                     JoinOn<T,U,K,R> on)

leftOuterJoin

public <U,K,R> ExStream<R> leftOuterJoin(java.util.stream.Stream<U> right,
                                         JoinOn<T,U,K,R> on)

rightOuterJoin

public <U,K,R> ExStream<R> rightOuterJoin(java.util.stream.Stream<U> right,
                                          JoinOn<T,U,K,R> on)

fullOuterJoin

public <U,K,R> ExStream<R> fullOuterJoin(java.util.stream.Stream<U> right,
                                         JoinOn<T,U,K,R> on)

cached

public ExStream<T> cached()

stream

public java.util.stream.Stream<T> stream()

of

public static <T> ExStream<T> of(JoinStream<T> joinStream)

of

public static <T> ExStream<T> of(java.util.stream.Stream<T> stream)

of

public static <T> ExStream<T> of(java.util.function.Supplier<java.util.stream.Stream<T>> streamProvider)

of

public static <T> ExStream<T> of(Collection<T> collection)

of

@SafeVarargs
public static <T> ExStream<T> of(T... values)