The ObservableBlockingSubscribe.observe function appears to compare the o variable, i.e. the ObservableSource, which shouldn't ever change, with BlockingObserver.TERMINATED. This will probably never be true. The intention was likely to use v instead of o, in:
|
|| o == BlockingObserver.TERMINATED |
Since this appears to be somewhat redundant with bs.isDisposed(), this probably does not cause any issues.