hu.akarnokd.reactive4java.reactive

Class Collect<U,T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Collect<U,T>

Type Parameters:

T - the source element type

U - the result element type

All Implemented Interfaces:

CloseableIterable<U>, java.lang.Iterable<U>

public final class Collect<U,T>
extends java.lang.Object
implements CloseableIterable<U>

Produces an iterable sequence that returns elements collected/aggregated/whatever from the source sequence between consequtive iteration. FIXME not sure how this should work as the return values depend on when the next() is invoked.

Since:

0.97

Field Summary

Fields

Modifier and Type	Field and Description
protected Func0<? extends U>	initialCollector The initial collector function.
protected Func2<? super U,? super T,? extends U>	merge The merger function.
protected Func1<? super U,? extends U>	newCollector The new collector function based on the current collector.
protected Observable<? extends T>	source The source sequence.

Constructor Summary

Constructors

Constructor and Description
Collect(Observable<? extends T> source, Func0<? extends U> initialCollector, Func2<? super U,? super T,? extends U> merge, Func1<? super U,? extends U> newCollector) Constructor.

Method Summary

Modifier and Type	Method and Description
CloseableIterator<U>	iterator()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

source

protected final Observable<? extends T> source

The source sequence.

newCollector

protected final Func1<? super U,? extends U> newCollector

The new collector function based on the current collector.

initialCollector

protected final Func0<? extends U> initialCollector

The initial collector function.

merge

protected final Func2<? super U,? super T,? extends U> merge

The merger function.

Constructor Detail

Collect

public Collect(Observable<? extends T> source,
               Func0<? extends U> initialCollector,
               Func2<? super U,? super T,? extends U> merge,
               Func1<? super U,? extends U> newCollector)

Constructor.

Parameters:

source - the source sequence

initialCollector - the initial collector factory

merge - the merger operator

newCollector - the factory to replace the current collector

Method Detail

iterator

public CloseableIterator<U> iterator()

Specified by:

iterator in interface CloseableIterable<U>

Specified by:

iterator in interface java.lang.Iterable<U>