File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
src/main/java/rx/internal/operators Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -98,7 +98,7 @@ public Notification<?> call(Notification<?> terminalNotification) {
98
98
}
99
99
100
100
public static final class RetryWithPredicate implements Func1 <Observable <? extends Notification <?>>, Observable <? extends Notification <?>>> {
101
- private Func2 <Integer , Throwable , Boolean > predicate ;
101
+ private final Func2 <Integer , Throwable , Boolean > predicate ;
102
102
103
103
public RetryWithPredicate (Func2 <Integer , Throwable , Boolean > predicate ) {
104
104
this .predicate = predicate ;
@@ -111,7 +111,7 @@ public Observable<? extends Notification<?>> call(Observable<? extends Notificat
111
111
@ Override
112
112
public Notification <Integer > call (Notification <Integer > n , Notification <?> term ) {
113
113
final int value = n .getValue ();
114
- if (predicate .call (value , term .getThrowable ()). booleanValue () )
114
+ if (predicate .call (value , term .getThrowable ()))
115
115
return Notification .createOnNext (value + 1 );
116
116
else
117
117
return (Notification <Integer >) term ;
You can’t perform that action at this time.
0 commit comments