Skip to content

Commit 765e918

Browse files
committed
make fields final
1 parent a56f78b commit 765e918

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/main/java/rx/internal/operators/OnSubscribeRedo.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -171,10 +171,10 @@ public static <T> Observable<T> redo(Observable<T> source, Func1<? super Observa
171171
return create(new OnSubscribeRedo<T>(source, notificationHandler, false, false, scheduler));
172172
}
173173

174-
private Observable<T> source;
174+
private final Observable<T> source;
175175
private final Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> controlHandlerFunction;
176-
private boolean stopOnComplete;
177-
private boolean stopOnError;
176+
private final boolean stopOnComplete;
177+
private final boolean stopOnError;
178178
private final Scheduler scheduler;
179179

180180
private OnSubscribeRedo(Observable<T> source, Func1<? super Observable<? extends Notification<?>>, ? extends Observable<?>> f, boolean stopOnComplete, boolean stopOnError,

0 commit comments

Comments
 (0)