ursus
05/05/2019, 5:20 PMObservablePublish
@Override
public void onError(Throwable e) {
current.compareAndSet(this, null);
InnerDisposable<T>[] a = observers.getAndSet(TERMINATED);
if (a.length != 0) {
for (InnerDisposable<T> inner : a) {
inner.child.onError(e);
}
} else {
RxJavaPlugins.onError(e); <-----
}
}