Package rx.internal.operators

Class OperatorSkipWhile<T>

java.lang.Object

rx.internal.operators.OperatorSkipWhile<T>

Type Parameters:

T - the value type

All Implemented Interfaces:

Func1<Subscriber<? super T>,Subscriber<? super T>>, Function, Observable.Operator<T,T>

public final class OperatorSkipWhile<T>
extends Object
implements Observable.Operator<T,T>

Skips any emitted source items as long as the specified condition holds true. Emits all further source items as soon as the condition becomes false.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final Func2<? super T,Integer,Boolean>	predicate

Constructor Summary

Constructors

Constructor	Description
OperatorSkipWhile(Func2<? super T,Integer,Boolean> predicate)

Method Summary

Modifier and Type	Method	Description
Subscriber<? super T>	call(Subscriber<? super T> child)
static <T> Func2<T,Integer,Boolean>	toPredicate2(Func1<? super T,Boolean> predicate)	Convert to Func2 type predicate.

Methods inherited from class java.lang.Object

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

Field Details

predicate

final Func2<? super T,Integer,Boolean> predicate

Constructor Details

OperatorSkipWhile

public OperatorSkipWhile(Func2<? super T,Integer,Boolean> predicate)

Method Details

call

public Subscriber<? super T> call(Subscriber<? super T> child)

Specified by:

call in interface Func1<Subscriber<? super T>,Subscriber<? super T>>

toPredicate2

public static <T> Func2<T,Integer,Boolean> toPredicate2(Func1<? super T,Boolean> predicate)

Convert to Func2 type predicate.

Type Parameters:

T - the input value type

Parameters:

predicate - the single argument predicate function

Returns:

The two argument function which ignores its second parameter