package f.a.r;

import f.a.f;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: compiled from: PublishSubject.java */
/* JADX INFO: loaded from: classes.dex */
public final class a<T> extends c<T> {

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    static final C0057a[] f942f = new C0057a[0];

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    static final C0057a[] f943g = new C0057a[0];
    final AtomicReference<C0057a<T>[]> b = new AtomicReference<>(f943g);

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    Throwable f944e;

    /* JADX INFO: renamed from: f.a.r.a$a, reason: collision with other inner class name */
    /* JADX INFO: compiled from: PublishSubject.java */
    static final class C0057a<T> extends AtomicBoolean implements f.a.k.b {
        final f<? super T> b;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        final a<T> f945e;

        C0057a(f<? super T> fVar, a<T> aVar) {
            this.b = fVar;
            this.f945e = aVar;
        }

        public boolean a() {
            return get();
        }

        public void b() {
            if (get()) {
                return;
            }
            this.b.b();
        }

        public void c(Throwable th) {
            if (get()) {
                f.a.p.a.m(th);
            } else {
                this.b.a(th);
            }
        }

        public void d(T t) {
            if (get()) {
                return;
            }
            this.b.d(t);
        }

        @Override // f.a.k.b
        public void dispose() {
            if (compareAndSet(false, true)) {
                this.f945e.y(this);
            }
        }
    }

    a() {
    }

    public static <T> a<T> x() {
        return new a<>();
    }

    @Override // f.a.f
    public void a(Throwable th) {
        if (this.b.get() == f942f) {
            f.a.p.a.m(th);
            return;
        }
        if (th == null) {
            th = new NullPointerException("onError called with null. Null values are generally not allowed in 2.x operators and sources.");
        }
        this.f944e = th;
        for (C0057a<T> c0057a : this.b.getAndSet(f942f)) {
            c0057a.c(th);
        }
    }

    @Override // f.a.f
    public void b() {
        C0057a<T>[] c0057aArr = this.b.get();
        C0057a<T>[] c0057aArr2 = f942f;
        if (c0057aArr == c0057aArr2) {
            return;
        }
        for (C0057a<T> c0057a : this.b.getAndSet(c0057aArr2)) {
            c0057a.b();
        }
    }

    @Override // f.a.f
    public void c(f.a.k.b bVar) {
        if (this.b.get() == f942f) {
            bVar.dispose();
        }
    }

    @Override // f.a.f
    public void d(T t) {
        if (this.b.get() == f942f) {
            return;
        }
        if (t == null) {
            a(new NullPointerException("onNext called with null. Null values are generally not allowed in 2.x operators and sources."));
            return;
        }
        for (C0057a<T> c0057a : this.b.get()) {
            c0057a.d(t);
        }
    }

    @Override // f.a.d
    public void q(f<? super T> fVar) {
        C0057a<T> c0057a = new C0057a<>(fVar, this);
        fVar.c(c0057a);
        if (w(c0057a)) {
            if (c0057a.a()) {
                y(c0057a);
            }
        } else {
            Throwable th = this.f944e;
            if (th != null) {
                fVar.a(th);
            } else {
                fVar.b();
            }
        }
    }

    boolean w(C0057a<T> c0057a) {
        C0057a<T>[] c0057aArr;
        C0057a<T>[] c0057aArr2;
        do {
            c0057aArr = this.b.get();
            if (c0057aArr == f942f) {
                return false;
            }
            int length = c0057aArr.length;
            c0057aArr2 = new C0057a[length + 1];
            System.arraycopy(c0057aArr, 0, c0057aArr2, 0, length);
            c0057aArr2[length] = c0057a;
        } while (!this.b.compareAndSet(c0057aArr, c0057aArr2));
        return true;
    }

    void y(C0057a<T> c0057a) {
        C0057a<T>[] c0057aArr;
        C0057a<T>[] c0057aArr2;
        do {
            c0057aArr = this.b.get();
            if (c0057aArr == f942f || c0057aArr == f943g) {
                return;
            }
            int length = c0057aArr.length;
            int i2 = -1;
            int i3 = 0;
            while (true) {
                if (i3 >= length) {
                    break;
                }
                if (c0057aArr[i3] == c0057a) {
                    i2 = i3;
                    break;
                }
                i3++;
            }
            if (i2 < 0) {
                return;
            }
            if (length == 1) {
                c0057aArr2 = f943g;
            } else {
                C0057a<T>[] c0057aArr3 = new C0057a[length - 1];
                System.arraycopy(c0057aArr, 0, c0057aArr3, 0, i2);
                System.arraycopy(c0057aArr, i2 + 1, c0057aArr3, i2, (length - i2) - 1);
                c0057aArr2 = c0057aArr3;
            }
        } while (!this.b.compareAndSet(c0057aArr, c0057aArr2));
    }
}