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 0eeee27 + 419dc0f commit 0005db1Copy full SHA for 0005db1
src/main/java/rx/internal/operators/OperatorPublish.java
@@ -535,10 +535,11 @@ void dispatch() {
535
// may contain less than requested
536
int d = 0;
537
while (d < maxRequested) {
538
+ term = terminalEvent;
539
Object v = queue.poll();
540
empty = v == null;
541
// let's check if there is a terminal event and the queue became empty just now
- if (checkTerminated(terminalEvent, empty)) {
542
+ if (checkTerminated(term, empty)) {
543
skipFinal = true;
544
return;
545
}
0 commit comments