https://kotlinlang.org logo
#rx
Title
u

ursus

05/05/2019, 5:20 PM
but then if error happens, it crashes on this
Copy code
ObservablePublish

        @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);  <-----
            }
        }