(RefreshSubject.RefreshDisposable<T> ps) {         for (;;) {             RefreshSubject.RefreshDisposable<T>[] a = subscribers.get();             if (a == TERMINATED) {                 return false;             }              int n = a.length;             @SuppressWarnings("unchecked")             RefreshSubject.RefreshDisposable<T>[] b