hu.akarnokd.reactive4java.reactive

Class Skip.While<T>

java.lang.Object

hu.akarnokd.reactive4java.reactive.Skip.While<T>

Type Parameters:

T - the element types

All Implemented Interfaces:

Observable<T>

Enclosing class:

Skip

public static final class Skip.While<T>
extends java.lang.Object
implements Observable<T>

Skips the Ts from source while the specified condition returns true. If the condition returns false, all subsequent Ts are relayed, ignoring the condition further on. Errors and completion is relayed regardless of the condition.

Constructor Summary

Constructors

Constructor and Description
While(Observable<? extends T> source, Func1<? super T,java.lang.Boolean> condition) 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

While

public While(Observable<? extends T> source,
             Func1<? super T,java.lang.Boolean> condition)

Constructor.

Parameters:

source - the source of Ts

condition - the condition that must turn false in order to start relaying

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