File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
src/main/java/io/reactivex/observers Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -248,7 +248,7 @@ public final int errorCount() {
248
248
* @return true if this TestSubscriber received a subscription
249
249
*/
250
250
public final boolean hasSubscription () {
251
- return subscription != null ;
251
+ return subscription . get () != null ;
252
252
}
253
253
254
254
/**
@@ -577,7 +577,7 @@ public final TestObserver<T> assertNotTerminated() {
577
577
* @return this;
578
578
*/
579
579
public final TestObserver <T > assertSubscribed () {
580
- if (subscription == null ) {
580
+ if (subscription . get () == null ) {
581
581
fail ("Not subscribed!" );
582
582
}
583
583
return this ;
@@ -588,7 +588,7 @@ public final TestObserver<T> assertSubscribed() {
588
588
* @return this;
589
589
*/
590
590
public final TestObserver <T > assertNotSubscribed () {
591
- if (subscription != null ) {
591
+ if (subscription . get () != null ) {
592
592
fail ("Subscribed!" );
593
593
} else
594
594
if (!errors .isEmpty ()) {
You can’t perform that action at this time.
0 commit comments