Skip to content

Commit 8a7f2ec

Browse files
committed
No need for direct disposable
1 parent 2182e90 commit 8a7f2ec

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

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

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ public Disposable scheduleDirect(Runnable run, final long delay, final TimeUnit
7878
Disposable delayed = HELPER.scheduleDirect(new Runnable() {
7979
@Override
8080
public void run() {
81-
dr.direct.replace(scheduleDirect(dr));
81+
executor.execute(dr);
8282
}
8383
}, delay, unit);
8484

@@ -278,12 +278,9 @@ static final class DelayedRunnable extends AtomicReference<Runnable> implements
278278

279279
final SequentialDisposable timed;
280280

281-
final SequentialDisposable direct;
282-
283281
DelayedRunnable(Runnable run) {
284282
super(run);
285283
this.timed = new SequentialDisposable();
286-
this.direct = new SequentialDisposable();
287284
}
288285

289286
@Override
@@ -295,7 +292,6 @@ public void run() {
295292
} finally {
296293
lazySet(null);
297294
timed.lazySet(DisposableHelper.DISPOSED);
298-
direct.lazySet(DisposableHelper.DISPOSED);
299295
}
300296
}
301297
}
@@ -309,7 +305,6 @@ public boolean isDisposed() {
309305
public void dispose() {
310306
if (getAndSet(null) != null) {
311307
timed.dispose();
312-
timed.dispose();
313308
}
314309
}
315310
}

0 commit comments

Comments
 (0)