Package com.github.tonivade.purefun.stream

Class Suspend<F extends Kind<F,?>,T>

java.lang.Object

com.github.tonivade.purefun.stream.Suspend<F,T>

All Implemented Interfaces:

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

public final class Suspend<F extends Kind<F,?>,T>
extends Object
implements PureStream<F,T>

Nested Class Summary

Nested classes/interfaces inherited from interface com.github.tonivade.purefun.stream.PureStream

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

Field Summary

Fields

Modifier and Type	Field	Description
private final Kind<F,PureStream<F,T>>	evalStream
private final MonadDefer<F>	monad

Constructor Summary

Constructors

Constructor	Description
Suspend(MonadDefer<F> monad, Kind<F,PureStream<F,T>> stream)

Method Summary

Modifier and Type	Method	Description
PureStream<F,T>	append(Kind<F,? extends T> other)
<R> PureStream<F,R>	collect(PartialFunction1<? super T,? extends R> partial)
PureStream<F,T>	concat(PureStream<F,? extends T> other)
PureStream<F,T>	drop(int n)
PureStream<F,T>	dropWhile(Matcher1<? super T> matcher)
Kind<F,Boolean>	exists(Matcher1<? super T> matcher)
PureStream<F,T>	filter(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)
Kind<F,Option<T>>	headOption()
PureStream<F,T>	intersperse(Kind<F,? extends T> value)
private <R> PureStream<F,R>	lazyMap(Function1<PureStream<F,T>,PureStream<F,R>> mapper)
<R> PureStream<F,R>	map(Function1<? super T,? extends R> mapper)
<R> PureStream<F,R>	mapEval(Function1<? super T,? extends Kind<F,? extends R>> mapper)
PureStream<F,T>	prepend(Kind<F,? extends T> other)
PureStream<F,T>	repeat()
Kind<F,Option<Tuple2<Kind<F,T>,PureStream<F,T>>>>	split()
private <R> PureStream<F,R>	suspend(Producer<Kind<F,PureStream<F,R>>> stream)
PureStream<F,T>	take(int n)
PureStream<F,T>	takeWhile(Matcher1<? super T> matcher)

Methods inherited from class java.lang.Object

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

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

fix, kind

Methods inherited from interface com.github.tonivade.purefun.stream.PureStream

andThen, asSequence, asString, drain, filterNot, head, mapReplace, tail, through

Field Details

monad

private final MonadDefer<F extends Kind<F,?>> monad

evalStream

private final Kind<F extends Kind<F,?>,PureStream<F extends Kind<F,?>,T>> evalStream

Constructor Details

Suspend

Suspend(MonadDefer<F> monad,
 Kind<F,PureStream<F,T>> stream)

Method Details

headOption

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

Specified by:

headOption in interface PureStream<F extends Kind<F,?>,T>

split

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

Specified by:

split in interface PureStream<F extends Kind<F,?>,T>

concat

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

Specified by:

concat in interface PureStream<F extends Kind<F,?>,T>

append

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

Specified by:

append in interface PureStream<F extends Kind<F,?>,T>

prepend

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

Specified by:

prepend in interface PureStream<F extends Kind<F,?>,T>

take

public PureStream<F,T> take(int n)

Specified by:

take in interface PureStream<F extends Kind<F,?>,T>

drop

public PureStream<F,T> drop(int n)

Specified by:

drop in interface PureStream<F extends Kind<F,?>,T>

takeWhile

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

Specified by:

takeWhile in interface PureStream<F extends Kind<F,?>,T>

dropWhile

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

Specified by:

dropWhile in interface PureStream<F extends Kind<F,?>,T>

filter

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

Specified by:

filter in interface PureStream<F extends Kind<F,?>,T>

collect

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

Specified by:

collect in interface PureStream<F extends Kind<F,?>,T>

foldLeft

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

Specified by:

foldLeft in interface PureStream<F extends Kind<F,?>,T>

foldRight

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

Specified by:

foldRight in interface PureStream<F extends Kind<F,?>,T>

exists

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

Specified by:

exists in interface PureStream<F extends Kind<F,?>,T>

forall

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

Specified by:

forall in interface PureStream<F extends Kind<F,?>,T>

map

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

Specified by:

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

Specified by:

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

Specified by:

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

mapEval

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

Specified by:

mapEval in interface PureStream<F extends Kind<F,?>,T>

flatMap

public <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>

Specified by:

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

repeat

public PureStream<F,T> repeat()

Specified by:

repeat in interface PureStream<F extends Kind<F,?>,T>

intersperse

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

Specified by:

intersperse in interface PureStream<F extends Kind<F,?>,T>

lazyMap

private <R> PureStream<F,R> lazyMap(Function1<PureStream<F,T>,PureStream<F,R>> mapper)

suspend

private <R> PureStream<F,R> suspend(Producer<Kind<F,PureStream<F,R>>> stream)