org.davidmoten.kool.internal.operators.stream

Class Collect<T,R>

java.lang.Object

org.davidmoten.kool.internal.operators.stream.Collect<T,R>

All Implemented Interfaces:

Iterable<R>, Single<R>, StreamIterable<R>

public final class Collect<T,R>
extends Object
implements Single<R>

Constructor Summary

Constructors

Constructor and Description
Collect(Callable<? extends R> factory, BiConsumer<? super R,? super T> collector, Stream<T> source)

Method Summary

Modifier and Type	Method and Description
R	get()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.davidmoten.kool.Single

doOnError, doOnValue, error, error, flatMap, flatMapMaybe, forEach, fromCallable, go, iterator, map, of, println, repeat, retryWhen, retryWhen, start, switchOnError, test, timer, timer, to, toStream

Methods inherited from interface org.davidmoten.kool.StreamIterable

iteratorNullChecked

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

Collect

public Collect(Callable<? extends R> factory,
               BiConsumer<? super R,? super T> collector,
               Stream<T> source)

Method Detail

get

public R get()

Specified by:

get in interface Single<R>