Skip to content

Commit e1cec33

Browse files
vanniktechakarnokd
authored andcommitted
2.x: Completable.test cancel TestSubscriber when wanted (#4395)
1 parent f0ba525 commit e1cec33

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

src/main/java/io/reactivex/Completable.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1694,7 +1694,10 @@ public final TestSubscriber<Void> test() {
16941694
*/
16951695
public final TestSubscriber<Void> test(boolean cancelled) {
16961696
TestSubscriber<Void> ts = new TestSubscriber<Void>();
1697-
ts.dispose();
1697+
1698+
if (cancelled) {
1699+
ts.cancel();
1700+
}
16981701
subscribe(new SubscriberCompletableObserver<Void>(ts));
16991702
return ts;
17001703
}

0 commit comments

Comments
 (0)