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 c694a2a commit 9f590cfCopy full SHA for 9f590cf
src/main/java/rx/Scheduler.java
@@ -20,7 +20,6 @@
20
import rx.functions.Action0;
21
import rx.schedulers.Schedulers;
22
import rx.subscriptions.MultipleAssignmentSubscription;
23
-import rx.subscriptions.SerialSubscription;
24
25
/**
26
* A {@code Scheduler} is an object that schedules units of work. You can find common implementations of this
@@ -124,7 +123,7 @@ public void call() {
124
123
}
125
126
};
127
- SerialSubscription s = new SerialSubscription();
+ MultipleAssignmentSubscription s = new MultipleAssignmentSubscription();
128
// Should call `mas.set` before `schedule`, or the new Subscription may replace the old one.
129
mas.set(s);
130
s.set(schedule(recursiveAction, initialDelay, unit));
0 commit comments