Skip to content

Commit 0554fb6

Browse files
committed
parameter time unit marked as @nonnull
1 parent 6102198 commit 0554fb6

File tree

3 files changed

+4
-3
lines changed

3 files changed

+4
-3
lines changed

src/main/java/io/reactivex/internal/schedulers/ComputationScheduler.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -199,7 +199,7 @@ public Disposable schedule(@NonNull Runnable action) {
199199
return EmptyDisposable.INSTANCE;
200200
}
201201

202-
return poolWorker.scheduleActual(action, 0, null, serial);
202+
return poolWorker.scheduleActual(action, 0, TimeUnit.MILLISECONDS, serial);
203203
}
204204
@NonNull
205205
@Override

src/main/java/io/reactivex/internal/schedulers/NewThreadWorker.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,8 @@ public Disposable schedulePeriodicallyDirect(final Runnable run, long initialDel
107107
* @param parent the optional tracker parent to add the created ScheduledRunnable instance to before it gets scheduled
108108
* @return the ScheduledRunnable instance
109109
*/
110-
public ScheduledRunnable scheduleActual(final Runnable run, long delayTime, TimeUnit unit, @Nullable DisposableContainer parent) {
110+
@NonNull
111+
public ScheduledRunnable scheduleActual(final Runnable run, long delayTime, @NonNull TimeUnit unit, @Nullable DisposableContainer parent) {
111112
Runnable decoratedRun = RxJavaPlugins.onSchedule(run);
112113

113114
ScheduledRunnable sr = new ScheduledRunnable(decoratedRun, parent);

src/test/java/io/reactivex/schedulers/NewThreadSchedulerTest.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ public void npe() throws Exception {
126126
@Override
127127
public void run() {
128128
}
129-
}, 0, null, null);
129+
}, 0, TimeUnit.MILLISECONDS, null);
130130

131131
}
132132
}

0 commit comments

Comments
 (0)