File tree Expand file tree Collapse file tree 1 file changed +3
-6
lines changed
src/main/java/rx/internal/operators Expand file tree Collapse file tree 1 file changed +3
-6
lines changed Original file line number Diff line number Diff line change @@ -399,14 +399,11 @@ private void completeInner() {
399
399
if (WIP_FOR_UNSUBSCRIBE_UPDATER .decrementAndGet (this ) == 0 ) {
400
400
// It means `groups.isEmpty() && child.isUnsubscribed()` is true
401
401
unsubscribe ();
402
- }
403
- // if we have no outstanding groups (all completed or unsubscribe) and terminated on outer
404
- if (groups .isEmpty () && terminated == TERMINATED_WITH_COMPLETED ) {
402
+ } else if (groups .isEmpty () && terminated == TERMINATED_WITH_COMPLETED ) {
403
+ // if we have no outstanding groups (all completed or unsubscribe) and terminated on outer
405
404
// completionEmitted ensures we only emit onCompleted once
406
405
if (COMPLETION_EMITTED_UPDATER .compareAndSet (this , 0 , 1 )) {
407
- if (!child .isUnsubscribed ()) {
408
- child .onCompleted ();
409
- }
406
+ child .onCompleted ();
410
407
}
411
408
}
412
409
}
You can’t perform that action at this time.
0 commit comments