hu.akarnokd.reactive4java.reactive

Class Where.IndexedFactory<T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Where.IndexedFactory<T>

Type Parameters:

T - the element type

All Implemented Interfaces:

Observable<T>

Enclosing class:

Where

public static final class Where.IndexedFactory<T>
extends java.lang.Object
implements Observable<T>

Creates a filtered observable where only Ts are relayed which satisfy the clause. The clause receives the index and the current element to test. The clauseFactory is used for each individual registering observer. This can be used to create memorizing filter functions such as distinct.

Constructor Summary

Constructors

Constructor and Description
IndexedFactory(Observable<? extends T> source, Func0<? extends Func2<? super T,? super java.lang.Integer,java.lang.Boolean>> clauseFactory) Constructor.

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	register(Observer<? super T> observer) Registers an observer for the notification of Ts.

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexedFactory

public IndexedFactory(Observable<? extends T> source,
                      Func0<? extends Func2<? super T,? super java.lang.Integer,java.lang.Boolean>> clauseFactory)

Constructor.

Parameters:

source - the source of Ts

clauseFactory - the filter clause, the first parameter receives the current index, the second receives the current element

Method Detail

register

@Nonnull
public java.io.Closeable register(@Nonnull
                                            Observer<? super T> observer)

Description copied from interface: Observable

Registers an observer for the notification of Ts.

Specified by:

register in interface Observable<T>

Parameters:

observer - the observer of Ts or any supertype of it

Returns:

the way of deregister the observer from this provider