We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent faf9d65 commit c694a2aCopy full SHA for c694a2a
src/main/java/rx/Scheduler.java
@@ -120,10 +120,7 @@ public void call() {
120
if (!mas.isUnsubscribed()) {
121
action.call();
122
long nextTick = startInNanos + (++count * periodInNanos);
123
- SerialSubscription s = new SerialSubscription();
124
- // Should call `mas.set` before `schedule`, or the new Subscription may replace the old one.
125
- mas.set(s);
126
- s.set(schedule(this, nextTick - TimeUnit.MILLISECONDS.toNanos(now()), TimeUnit.NANOSECONDS));
+ mas.set(schedule(this, nextTick - TimeUnit.MILLISECONDS.toNanos(now()), TimeUnit.NANOSECONDS));
127
}
128
129
};
0 commit comments