Package com.github.tonivade.purefun.stream

Interface PureStream.Of<F extends Kind<F,?>>

Enclosing interface:

PureStream<F extends Kind<F,?>,T>

public static interface PureStream.Of<F extends Kind<F,?>>

Method Summary

Modifier and Type	Method	Description
default <T> PureStream<F,T>	cons(T head, PureStream<F,? extends T> tail)
private <T, S> PureStream<F,T>	doUnfold(S seed, Function1<? super S,Option<Tuple2<? extends T,? extends S>>> function)
default <T> PureStream<F,T>	empty()
default <T> PureStream<F,T>	eval(Kind<F,? extends T> value)
default <T> PureStream<F,T>	from(Sequence<? extends T> sequence)
default <T> PureStream<F,T>	from(Iterable<? extends T> iterable)
default <T> PureStream<F,T>	from(Stream<? extends T> stream)
default <T> PureStream<F,T>	iterate(Producer<? extends T> generator)
default <T> PureStream<F,T>	iterate(T seed, Operator1<T> generator)
default <A> PureStream<F,A>	merge(PureStream<F,A> s1, PureStream<F,A> s2)
MonadDefer<F>	monadDefer()
default <T> PureStream<F,T>	of(T... values)
default <T> PureStream<F,T>	pure(T value)
default <T> PureStream<F,T>	suspend(Producer<? extends PureStream<F,? extends T>> lazy)
default <T, S> PureStream<F,T>	unfold(S seed, Function1<? super S,Option<Tuple2<? extends T,? extends S>>> function)
default <A, B> PureStream<F,Tuple2<A,B>>	zip(PureStream<F,? extends A> s1, PureStream<F,? extends B> s2)
default <A, B, R> PureStream<F,R>	zipWith(PureStream<F,? extends A> s1, PureStream<F,? extends B> s2, Function2<? super A,? super B,? extends R> combinator)
default <A> PureStream<F,Tuple2<A,Integer>>	zipWithIndex(PureStream<F,? extends A> stream)

Method Details

monadDefer

MonadDefer<F> monadDefer()

empty

default <T> PureStream<F,T> empty()

of

default <T> PureStream<F,T> of(T... values)

pure

default <T> PureStream<F,T> pure(T value)

cons

default <T> PureStream<F,T> cons(T head,
 PureStream<F,? extends T> tail)

suspend

default <T> PureStream<F,T> suspend(Producer<? extends PureStream<F,? extends T>> lazy)

eval

default <T> PureStream<F,T> eval(Kind<F,? extends T> value)

from

default <T> PureStream<F,T> from(Iterable<? extends T> iterable)

from

default <T> PureStream<F,T> from(Stream<? extends T> stream)

from

default <T> PureStream<F,T> from(Sequence<? extends T> sequence)

unfold

default <T,
S> PureStream<F,T> unfold(S seed,
 Function1<? super S,Option<Tuple2<? extends T,? extends S>>> function)

iterate

default <T> PureStream<F,T> iterate(T seed,
 Operator1<T> generator)

iterate

default <T> PureStream<F,T> iterate(Producer<? extends T> generator)

zipWith

default <A,
B,
R> PureStream<F,R> zipWith(PureStream<F,? extends A> s1,
 PureStream<F,? extends B> s2,
 Function2<? super A,? super B,? extends R> combinator)

zip

default <A,
B> PureStream<F,Tuple2<A,B>> zip(PureStream<F,? extends A> s1,
 PureStream<F,? extends B> s2)

zipWithIndex

default <A> PureStream<F,Tuple2<A,Integer>> zipWithIndex(PureStream<F,? extends A> stream)

merge

default <A> PureStream<F,A> merge(PureStream<F,A> s1,
 PureStream<F,A> s2)

doUnfold

private <T,
S> PureStream<F,T> doUnfold(S seed,
 Function1<? super S,Option<Tuple2<? extends T,? extends S>>> function)