From 48c46c210b53683e87d6e94a5c09d4f051553b3c Mon Sep 17 00:00:00 2001
From: akarnokd <akarnokd@gmail.com>
Date: Mon, 30 Apr 2018 12:08:15 +0200
Subject: [PATCH] 2.x: Cleanup in the Scheduler class

---
 src/main/java/io/reactivex/Scheduler.java | 14 +++++++++++---
 1 file changed, 11 insertions(+), 3 deletions(-)

diff --git a/src/main/java/io/reactivex/Scheduler.java b/src/main/java/io/reactivex/Scheduler.java
index 44a5b1830f..0f4806d4a0 100644
--- a/src/main/java/io/reactivex/Scheduler.java
+++ b/src/main/java/io/reactivex/Scheduler.java
@@ -510,12 +510,15 @@ public Runnable getWrappedRunnable() {
         }
     }
 
-    static class PeriodicDirectTask
+    static final class PeriodicDirectTask
     implements Disposable, Runnable, SchedulerRunnableIntrospection {
+
+        @NonNull
         final Runnable run;
+
         @NonNull
         final Worker worker;
-        @NonNull
+
         volatile boolean disposed;
 
         PeriodicDirectTask(@NonNull Runnable run, @NonNull Worker worker) {
@@ -554,12 +557,17 @@ public Runnable getWrappedRunnable() {
     }
 
     static final class DisposeTask implements Disposable, Runnable, SchedulerRunnableIntrospection {
+
+        @NonNull
         final Runnable decoratedRun;
+
+        @NonNull
         final Worker w;
 
+        @Nullable
         Thread runner;
 
-        DisposeTask(Runnable decoratedRun, Worker w) {
+        DisposeTask(@NonNull Runnable decoratedRun, @NonNull Worker w) {
             this.decoratedRun = decoratedRun;
             this.w = w;
         }