Package com.github.tonivade.purefun.stream

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

All Superinterfaces:

Bindable<PureStream<F,?>,T>, Kind<PureStream<F,?>,T>, Mappable<PureStream<F,?>,T>, PureStreamOf<F,T>

All Known Implementing Classes:

Cons, Nil, Suspend

public sealed interface PureStream<F extends Kind<F,?>,T>
extends PureStreamOf<F,T>, Bindable<PureStream<F,?>,T>
permits Cons<F,T>, Suspend<F,T>, Nil<F,T>

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	PureStream.Of<F extends Kind<F,?>>

Method Summary

Modifier and Type	Method	Description
default <R> PureStream<F,R>	andThen(Kind<PureStream<F,?>,? extends R> next)
PureStream<F,T>	append(Kind<F,? extends T> other)
default Kind<F,Sequence<T>>	asSequence()
default Kind<F,String>	asString()
<R> PureStream<F,R>	collect(PartialFunction1<? super T,? extends R> partial)
PureStream<F,T>	concat(PureStream<F,? extends T> other)
static <F extends Kind<F, ?>, T> PureStream<F,T>	cons(T head, PureStream<F,? extends T> tail, F... reified)
default Kind<F,Unit>	drain()
PureStream<F,T>	drop(int n)
PureStream<F,T>	dropWhile(Matcher1<? super T> matcher)
static <F extends Kind<F, ?>, T> PureStream<F,T>	empty(F... reified)
static <F extends Kind<F, ?>, T> PureStream<F,T>	eval(Kind<F,? extends T> value, F... reified)
Kind<F,Boolean>	exists(Matcher1<? super T> matcher)
PureStream<F,T>	filter(Matcher1<? super T> matcher)
default PureStream<F,T>	filterNot(Matcher1<? super T> matcher)
<R> PureStream<F,R>	flatMap(Function1<? super T,? extends Kind<PureStream<F,?>,? extends R>> map)
<R> Kind<F,R>	foldLeft(R begin, Function2<? super R,? super T,? extends R> combinator)
<R> Kind<F,R>	foldRight(Kind<F,? extends R> begin, Function2<? super T,? super Kind<F,? extends R>,? extends Kind<F,? extends R>> combinator)
Kind<F,Boolean>	forall(Matcher1<? super T> matcher)
static <F extends Kind<F, ?>, T> PureStream<F,T>	from(Sequence<? extends T> sequence, F... reified)
static <F extends Kind<F, ?>, T> PureStream<F,T>	from(Iterable<? extends T> iterable, F... reified)
static <F extends Kind<F, ?>, T> PureStream<F,T>	from(Stream<? extends T> stream, F... reified)
default PureStream<F,T>	head()
Kind<F,Option<T>>	headOption()
PureStream<F,T>	intersperse(Kind<F,? extends T> value)
static <F extends Kind<F, ?>, T> PureStream<F,T>	iterate(Producer<? extends T> generator, F... reified)
static <F extends Kind<F, ?>, T> PureStream<F,T>	iterate(T seed, Operator1<T> generator, F... reified)
<R> PureStream<F,R>	map(Function1<? super T,? extends R> map)
<R> PureStream<F,R>	mapEval(Function1<? super T,? extends Kind<F,? extends R>> mapper)
default <R> PureStream<F,R>	mapReplace(Kind<F,? extends R> next)
static <F extends Kind<F, ?>, A> PureStream<F,A>	merge(PureStream<F,A> s1, PureStream<F,A> s2, F... reified)
static <F extends Kind<F, ?>> PureStream.Of<F>	of(MonadDefer<F> monad)
static <F extends Kind<F, ?>> PureStream.Of<F>	of(F... reified)
static <F extends Kind<F, ?>> PureStream.Of<F>	of(Class<F> type)
PureStream<F,T>	prepend(Kind<F,? extends T> other)
static <F extends Kind<F, ?>, T> PureStream<F,T>	pure(T value, F... reified)
PureStream<F,T>	repeat()
Kind<F,Option<Tuple2<Kind<F,T>,PureStream<F,T>>>>	split()
static <F extends Kind<F, ?>, T> PureStream<F,T>	suspend(Producer<? extends PureStream<F,? extends T>> lazy, F... reified)
default PureStream<F,T>	tail()
PureStream<F,T>	take(int n)
PureStream<F,T>	takeWhile(Matcher1<? super T> matcher)
default <G extends Kind<G, ?>, R> PureStream<G,R>	through(Function1<PureStream<F,T>,PureStream<G,R>> function)
static <F extends Kind<F, ?>, T, S> PureStream<F,T>	unfold(S seed, Function1<? super S,Option<Tuple2<? extends T,? extends S>>> function, F... reified)
static <F extends Kind<F, ?>, A, B> PureStream<F,Tuple2<A,B>>	zip(PureStream<F,? extends A> s1, PureStream<F,? extends B> s2, F... reified)
static <F extends Kind<F, ?>, 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, F... reified)
static <F extends Kind<F, ?>, A> PureStream<F,Tuple2<A,Integer>>	zipWithIndex(PureStream<F,? extends A> stream, F... reified)

Methods inherited from interface com.github.tonivade.purefun.Kind

fix, kind

Method Details

head

default PureStream<F,T> head()

tail

default PureStream<F,T> tail()

headOption

Kind<F,Option<T>> headOption()

split

Kind<F,Option<Tuple2<Kind<F,T>,PureStream<F,T>>>> split()

concat

PureStream<F,T> concat(PureStream<F,? extends T> other)

append

PureStream<F,T> append(Kind<F,? extends T> other)

prepend

PureStream<F,T> prepend(Kind<F,? extends T> other)

take

PureStream<F,T> take(int n)

drop

PureStream<F,T> drop(int n)

filter

PureStream<F,T> filter(Matcher1<? super T> matcher)

takeWhile

PureStream<F,T> takeWhile(Matcher1<? super T> matcher)

dropWhile

PureStream<F,T> dropWhile(Matcher1<? super T> matcher)

filterNot

default PureStream<F,T> filterNot(Matcher1<? super T> matcher)

collect

<R> PureStream<F,R> collect(PartialFunction1<? super T,? extends R> partial)

foldLeft

<R> Kind<F,R> foldLeft(R begin,
 Function2<? super R,? super T,? extends R> combinator)

foldRight

<R> Kind<F,R> foldRight(Kind<F,? extends R> begin,
 Function2<? super T,? super Kind<F,? extends R>,? extends Kind<F,? extends R>> combinator)

map

<R> PureStream<F,R> map(Function1<? super T,? extends R> map)

Specified by:

map in interface Bindable<F extends Kind<F,?>,T>

Specified by:

map in interface Mappable<F extends Kind<F,?>,T>

flatMap

<R> PureStream<F,R> flatMap(Function1<? super T,? extends Kind<PureStream<F,?>,? extends R>> map)

Specified by:

flatMap in interface Bindable<F extends Kind<F,?>,T>

andThen

default <R> PureStream<F,R> andThen(Kind<PureStream<F,?>,? extends R> next)

Specified by:

andThen in interface Bindable<F extends Kind<F,?>,T>

mapEval

<R> PureStream<F,R> mapEval(Function1<? super T,? extends Kind<F,? extends R>> mapper)

repeat

PureStream<F,T> repeat()

intersperse

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

exists

Kind<F,Boolean> exists(Matcher1<? super T> matcher)

forall

Kind<F,Boolean> forall(Matcher1<? super T> matcher)

through

default <G extends Kind<G,
?>,
R> PureStream<G,R> through(Function1<PureStream<F,T>,PureStream<G,R>> function)

asSequence

default Kind<F,Sequence<T>> asSequence()

asString

default Kind<F,String> asString()

drain

default Kind<F,Unit> drain()

mapReplace

default <R> PureStream<F,R> mapReplace(Kind<F,? extends R> next)

of

static <F extends Kind<F,
?>> PureStream.Of<F> of(MonadDefer<F> monad)

of

static <F extends Kind<F,
?>> PureStream.Of<F> of(Class<F> type)

of

@SafeVarargs
static <F extends Kind<F,
?>> PureStream.Of<F> of(F... reified)

empty

@SafeVarargs
static <F extends Kind<F,
?>,
T> PureStream<F,T> empty(F... reified)

pure

@SafeVarargs
static <F extends Kind<F,
?>,
T> PureStream<F,T> pure(T value,
 F... reified)

cons

@SafeVarargs
static <F extends Kind<F,
?>,
T> PureStream<F,T> cons(T head,
 PureStream<F,? extends T> tail,
 F... reified)

suspend

@SafeVarargs
static <F extends Kind<F,
?>,
T> PureStream<F,T> suspend(Producer<? extends PureStream<F,? extends T>> lazy,
 F... reified)

eval

@SafeVarargs
static <F extends Kind<F,
?>,
T> PureStream<F,T> eval(Kind<F,? extends T> value,
 F... reified)

from

@SafeVarargs
static <F extends Kind<F,
?>,
T> PureStream<F,T> from(Iterable<? extends T> iterable,
 F... reified)

from

@SafeVarargs
static <F extends Kind<F,
?>,
T> PureStream<F,T> from(Stream<? extends T> stream,
 F... reified)

from

@SafeVarargs
static <F extends Kind<F,
?>,
T> PureStream<F,T> from(Sequence<? extends T> sequence,
 F... reified)

unfold

@SafeVarargs
static <F extends Kind<F,
?>,
T,
S> PureStream<F,T> unfold(S seed,
 Function1<? super S,Option<Tuple2<? extends T,? extends S>>> function,
 F... reified)

iterate

@SafeVarargs
static <F extends Kind<F,
?>,
T> PureStream<F,T> iterate(T seed,
 Operator1<T> generator,
 F... reified)

iterate

@SafeVarargs
static <F extends Kind<F,
?>,
T> PureStream<F,T> iterate(Producer<? extends T> generator,
 F... reified)

zipWith

@SafeVarargs
static <F extends Kind<F,
?>,
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,
 F... reified)

zip

@SafeVarargs
static <F extends Kind<F,
?>,
A,
B>
PureStream<F,Tuple2<A,B>> zip(PureStream<F,? extends A> s1,
 PureStream<F,? extends B> s2,
 F... reified)

zipWithIndex

@SafeVarargs
static <F extends Kind<F,
?>,
A>
PureStream<F,Tuple2<A,Integer>> zipWithIndex(PureStream<F,? extends A> stream,
 F... reified)

merge

@SafeVarargs
static <F extends Kind<F,
?>,
A> PureStream<F,A> merge(PureStream<F,A> s1,
 PureStream<F,A> s2,
 F... reified)