File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
rxjava-core/src/main/java/rx/schedulers Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change 25
25
import java .util .concurrent .*;
26
26
import java .util .concurrent .atomic .AtomicIntegerFieldUpdater ;
27
27
28
- /* package */ class CachedThreadScheduler extends Scheduler {
28
+ /* package */ final class CachedThreadScheduler extends Scheduler {
29
29
private static final String WORKER_THREAD_NAME_PREFIX = "RxCachedThreadScheduler-" ;
30
30
private static final NewThreadScheduler .RxThreadFactory WORKER_THREAD_FACTORY =
31
31
new NewThreadScheduler .RxThreadFactory (WORKER_THREAD_NAME_PREFIX );
@@ -106,7 +106,7 @@ public Worker createWorker() {
106
106
return new EventLoopWorker (CachedWorkerPool .INSTANCE .get ());
107
107
}
108
108
109
- private static class EventLoopWorker extends Scheduler .Worker {
109
+ private static final class EventLoopWorker extends Scheduler .Worker {
110
110
private final CompositeSubscription innerSubscription = new CompositeSubscription ();
111
111
private final ThreadWorker threadWorker ;
112
112
volatile int once ;
You can’t perform that action at this time.
0 commit comments