2.x: ObservableBlockingSubscribe compares with wrong object (#6601)

Author: akarnokd

src/main/java/io/reactivex/internal/operators/observable/ObservableBlockingSubscribe.java

@@ -61,7 +61,7 @@ public static <T> void subscribe(ObservableSource<? extends T> o, Observer<? sup
                 }
             }
             if (bs.isDisposed()
-                    || o == BlockingObserver.TERMINATED
+                    || v == BlockingObserver.TERMINATED
                     || NotificationLite.acceptFull(v, observer)) {
                 break;
             }