rx.operators

Class OperatorConditionalBinding<T,R>

java.lang.Object

rx.operators.OperatorConditionalBinding<T,R>

Type Parameters:

T - the type of the objects emitted to a subscriber

R - the type of the target object to bind to

All Implemented Interfaces:

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

public final class OperatorConditionalBinding<T,R>
extends java.lang.Object
implements rx.Observable.Operator<T,T>

Ties a source sequence to the given target object using a predicate. If the predicate fails to validate, the sequence unsubscribes itself and releases the bound reference.

You can also pass in an optional predicate function, which whenever it evaluates to false on the target object, will also result in the operator unsubscribing from the sequence.

Constructor Summary

Constructors

Constructor and Description
OperatorConditionalBinding(R bound)
OperatorConditionalBinding(R bound, rx.functions.Func1<? super R,java.lang.Boolean> predicate)

Method Summary

Methods

Modifier and Type	Method and Description
rx.Subscriber<? super T>	call(rx.Subscriber<? super T> child)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorConditionalBinding

public OperatorConditionalBinding(R bound,
                          rx.functions.Func1<? super R,java.lang.Boolean> predicate)

OperatorConditionalBinding

public OperatorConditionalBinding(R bound)

Method Detail

call

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

Specified by:

call in interface rx.functions.Func1<rx.Subscriber<? super T>,rx.Subscriber<? super T>>