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 f1be5f4 commit 429611eCopy full SHA for 429611e
rxjava-core/src/main/java/rx/operators/ScheduledObserver.java
@@ -64,8 +64,6 @@ private void processQueue() {
64
scheduler.schedule(new Action0() {
65
@Override
66
public void call() {
67
- int count = counter.decrementAndGet();
68
-
69
Notification<T> not = queue.poll();
70
71
switch (not.getKind()) {
@@ -83,6 +81,7 @@ public void call() {
83
81
84
82
}
85
+ int count = counter.decrementAndGet();
86
if (count > 0) {
87
scheduler.schedule(this);
88
0 commit comments