Skip to content

Commit cec8915

Browse files
authored
Fix the initialization of Completable.complete() (#4146)
1 parent ee63aff commit cec8915

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/main/java/rx/Completable.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -93,15 +93,15 @@ public void call(CompletableSubscriber s) {
9393
s.onSubscribe(Subscriptions.unsubscribed());
9494
s.onCompleted();
9595
}
96-
}, true); // hook is handled in complete()
96+
}, false); // hook is handled in complete()
9797

9898
/** Single instance of a never Completable. */
9999
static final Completable NEVER = new Completable(new CompletableOnSubscribe() {
100100
@Override
101101
public void call(CompletableSubscriber s) {
102102
s.onSubscribe(Subscriptions.unsubscribed());
103103
}
104-
}, true); // hook is handled in never()
104+
}, false); // hook is handled in never()
105105

106106
/**
107107
* Returns a Completable which terminates as soon as one of the source Completables
@@ -315,7 +315,7 @@ public static Completable complete() {
315315
if (cos == COMPLETE.onSubscribe) {
316316
return COMPLETE;
317317
}
318-
return new Completable(cos, true);
318+
return new Completable(cos, false);
319319
}
320320

321321
/**
@@ -742,7 +742,7 @@ public static Completable never() {
742742
if (cos == NEVER.onSubscribe) {
743743
return NEVER;
744744
}
745-
return new Completable(cos, true);
745+
return new Completable(cos, false);
746746
}
747747

748748
/**

0 commit comments

Comments
 (0)