hu.akarnokd.reactive4java.reactive

Class Take.WhileIndexed<T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Take.WhileIndexed<T>

Type Parameters:

T - the element type

All Implemented Interfaces:

Observable<T>

Enclosing class:

Take

public static class Take.WhileIndexed<T>
extends java.lang.Object
implements Observable<T>

Creates an observable which takes values from source until the indexed predicate returns false for the current element, then skips the remaining values.

Field Summary

Fields

Modifier and Type	Field and Description
protected Func2<? super T,? super java.lang.Integer,java.lang.Boolean>	predicate
protected Observable<? extends T>	source

Constructor Summary

Constructors

Constructor and Description
WhileIndexed(Observable<? extends T> source, Func2<? super T,? super java.lang.Integer,java.lang.Boolean> predicate) 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

Field Detail

source

protected final Observable<? extends T> source

predicate

protected final Func2<? super T,? super java.lang.Integer,java.lang.Boolean> predicate

Constructor Detail

WhileIndexed

public WhileIndexed(Observable<? extends T> source,
                    Func2<? super T,? super java.lang.Integer,java.lang.Boolean> predicate)

Constructor.

Parameters:

source - the source of Ts

predicate - the predicate

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