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.
2 parents 68f7f66 + 9f590cf commit d1034edCopy full SHA for d1034ed
src/main/java/rx/Scheduler.java
@@ -123,7 +123,10 @@ public void call() {
123
}
124
125
};
126
- mas.set(schedule(recursiveAction, initialDelay, unit));
+ MultipleAssignmentSubscription s = new MultipleAssignmentSubscription();
127
+ // Should call `mas.set` before `schedule`, or the new Subscription may replace the old one.
128
+ mas.set(s);
129
+ s.set(schedule(recursiveAction, initialDelay, unit));
130
return mas;
131
132
0 commit comments