Package rx.internal.operators
Class OnSubscribeRedo.RetryWithPredicate
- java.lang.Object
-
- rx.internal.operators.OnSubscribeRedo.RetryWithPredicate
-
- All Implemented Interfaces:
Func1<Observable<? extends Notification<?>>,Observable<? extends Notification<?>>>
,Function
- Enclosing class:
- OnSubscribeRedo<T>
public static final class OnSubscribeRedo.RetryWithPredicate extends java.lang.Object implements Func1<Observable<? extends Notification<?>>,Observable<? extends Notification<?>>>
-
-
Constructor Summary
Constructors Constructor Description RetryWithPredicate(Func2<java.lang.Integer,java.lang.Throwable,java.lang.Boolean> predicate)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Observable<? extends Notification<?>>
call(Observable<? extends Notification<?>> ts)
-
-
-
Field Detail
-
predicate
final Func2<java.lang.Integer,java.lang.Throwable,java.lang.Boolean> predicate
-
-
Constructor Detail
-
RetryWithPredicate
public RetryWithPredicate(Func2<java.lang.Integer,java.lang.Throwable,java.lang.Boolean> predicate)
-
-
Method Detail
-
call
public Observable<? extends Notification<?>> call(Observable<? extends Notification<?>> ts)
- Specified by:
call
in interfaceFunc1<Observable<? extends Notification<?>>,Observable<? extends Notification<?>>>
-
-