com.aol.cyclops2.internal.adapters

Class StreamAdapter<W extends Witness.StreamWitness<W>>

java.lang.Object

com.aol.cyclops2.types.extensability.AbstractFunctionalAdapter<W>

com.aol.cyclops2.internal.adapters.StreamAdapter<W>

All Implemented Interfaces:

FunctionalAdapter<W>

public class StreamAdapter<W extends Witness.StreamWitness<W>>
extends AbstractFunctionalAdapter<W>

Nested Class Summary

Nested classes/interfaces inherited from interface com.aol.cyclops2.types.extensability.FunctionalAdapter

FunctionalAdapter.ValueIterator<T>

Field Summary

Fields

Modifier and Type	Field and Description
static StreamAdapter	futureStream
static StreamAdapter	reactiveSeq
static StreamAdapter	stream

Constructor Summary

Constructors

Constructor and Description
StreamAdapter(java.util.function.Supplier<java.util.stream.Stream<?>> empty, java.util.function.Function<?,java.util.stream.Stream<?>> unit, java.util.function.Function<java.util.Iterator<?>,java.util.stream.Stream<?>> unitIterator, W witness)

Method Summary

Modifier and Type	Method and Description
<T,R> AnyM<W,R>	ap(AnyM<W,? extends java.util.function.Function<? super T,? extends R>> fn, AnyM<W,T> apply)
<T> AnyM<W,T>	empty()
<T> AnyM<W,T>	filter(AnyM<W,T> t, java.util.function.Predicate<? super T> fn)
<T,R> AnyM<W,R>	flatMap(AnyM<W,T> t, java.util.function.Function<? super T,? extends AnyM<W,? extends R>> fn)
<T,R> AnyM<W,R>	map(AnyM<W,T> t, java.util.function.Function<? super T,? extends R> fn)
<T> java.lang.Iterable<T>	toIterable(AnyM<W,T> t)
<T> ReactiveSeq<T>	toStream(AnyM<W,T> t)
<T> AnyM<W,T>	unit(T o)
<T> AnyM<W,T>	unitIterable(java.lang.Iterable<T> it)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.aol.cyclops2.types.extensability.FunctionalAdapter

ap2, isFilterable, visit

Field Detail

stream

public static final StreamAdapter stream

reactiveSeq

public static final StreamAdapter reactiveSeq

futureStream

public static final StreamAdapter futureStream

Constructor Detail

StreamAdapter

public StreamAdapter(java.util.function.Supplier<java.util.stream.Stream<?>> empty,
                     java.util.function.Function<?,java.util.stream.Stream<?>> unit,
                     java.util.function.Function<java.util.Iterator<?>,java.util.stream.Stream<?>> unitIterator,
                     W witness)

Method Detail

toIterable

public <T> java.lang.Iterable<T> toIterable(AnyM<W,T> t)

filter

public <T> AnyM<W,T> filter(AnyM<W,T> t,
                            java.util.function.Predicate<? super T> fn)

empty

public <T> AnyM<W,T> empty()

ap

public <T,R> AnyM<W,R> ap(AnyM<W,? extends java.util.function.Function<? super T,? extends R>> fn,
                          AnyM<W,T> apply)

Specified by:

ap in interface FunctionalAdapter<W extends Witness.StreamWitness<W>>

Specified by:

ap in class AbstractFunctionalAdapter<W extends Witness.StreamWitness<W>>

flatMap

public <T,R> AnyM<W,R> flatMap(AnyM<W,T> t,
                               java.util.function.Function<? super T,? extends AnyM<W,? extends R>> fn)

Specified by:

flatMap in interface FunctionalAdapter<W extends Witness.StreamWitness<W>>

Specified by:

flatMap in class AbstractFunctionalAdapter<W extends Witness.StreamWitness<W>>

unitIterable

public <T> AnyM<W,T> unitIterable(java.lang.Iterable<T> it)

Specified by:

unitIterable in interface FunctionalAdapter<W extends Witness.StreamWitness<W>>

Specified by:

unitIterable in class AbstractFunctionalAdapter<W extends Witness.StreamWitness<W>>

unit

public <T> AnyM<W,T> unit(T o)

map

public <T,R> AnyM<W,R> map(AnyM<W,T> t,
                           java.util.function.Function<? super T,? extends R> fn)

Specified by:

map in interface FunctionalAdapter<W extends Witness.StreamWitness<W>>

Overrides:

map in class AbstractFunctionalAdapter<W extends Witness.StreamWitness<W>>

toStream

public <T> ReactiveSeq<T> toStream(AnyM<W,T> t)