package f.a.a0;

import f.a.n;
import java.util.Objects;
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 b<T> extends d<T> {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final a[] f3687b = new a[0];

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public static final a[] f3688e = new a[0];

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final AtomicReference<a<T>[]> f3689f = new AtomicReference<>(f3688e);

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public Throwable f3690g;

    /* JADX INFO: compiled from: PublishSubject.java */
    public static final class a<T> extends AtomicBoolean implements f.a.t.b {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final n<? super T> f3691b;

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

        public a(n<? super T> nVar, b<T> bVar) {
            this.f3691b = nVar;
            this.f3692e = bVar;
        }

        @Override // f.a.t.b
        public void dispose() {
            if (compareAndSet(false, true)) {
                this.f3692e.D(this);
            }
        }
    }

    public void D(a<T> aVar) {
        a<T>[] aVarArr;
        a<T>[] aVarArr2;
        do {
            aVarArr = this.f3689f.get();
            if (aVarArr == f3687b || aVarArr == f3688e) {
                return;
            }
            int length = aVarArr.length;
            int i2 = 0;
            while (true) {
                if (i2 >= length) {
                    i2 = -1;
                    break;
                } else if (aVarArr[i2] == aVar) {
                    break;
                } else {
                    i2++;
                }
            }
            if (i2 < 0) {
                return;
            }
            if (length == 1) {
                aVarArr2 = f3688e;
            } else {
                a<T>[] aVarArr3 = new a[length - 1];
                System.arraycopy(aVarArr, 0, aVarArr3, 0, i2);
                System.arraycopy(aVarArr, i2 + 1, aVarArr3, i2, (length - i2) - 1);
                aVarArr2 = aVarArr3;
            }
        } while (!this.f3689f.compareAndSet(aVarArr, aVarArr2));
    }

    @Override // f.a.n
    public void a(Throwable th) {
        Objects.requireNonNull(th, "onError called with null. Null values are generally not allowed in 2.x operators and sources.");
        a<T>[] aVarArr = this.f3689f.get();
        a<T>[] aVarArr2 = f3687b;
        if (aVarArr == aVarArr2) {
            f.a.y.a.C0(th);
            return;
        }
        this.f3690g = th;
        for (a<T> aVar : this.f3689f.getAndSet(aVarArr2)) {
            if (aVar.get()) {
                f.a.y.a.C0(th);
            } else {
                aVar.f3691b.a(th);
            }
        }
    }

    @Override // f.a.n
    public void b(f.a.t.b bVar) {
        if (this.f3689f.get() == f3687b) {
            bVar.dispose();
        }
    }

    @Override // f.a.n
    public void c(T t) {
        Objects.requireNonNull(t, "onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
        for (a<T> aVar : this.f3689f.get()) {
            if (!aVar.get()) {
                aVar.f3691b.c(t);
            }
        }
    }

    @Override // f.a.n
    public void onComplete() {
        a<T>[] aVarArr = this.f3689f.get();
        a<T>[] aVarArr2 = f3687b;
        if (aVarArr == aVarArr2) {
            return;
        }
        for (a<T> aVar : this.f3689f.getAndSet(aVarArr2)) {
            if (!aVar.get()) {
                aVar.f3691b.onComplete();
            }
        }
    }

    @Override // f.a.i
    public void v(n<? super T> nVar) {
        boolean z;
        a<T> aVar = new a<>(nVar, this);
        nVar.b(aVar);
        while (true) {
            a<T>[] aVarArr = this.f3689f.get();
            z = false;
            if (aVarArr == f3687b) {
                break;
            }
            int length = aVarArr.length;
            a<T>[] aVarArr2 = new a[length + 1];
            System.arraycopy(aVarArr, 0, aVarArr2, 0, length);
            aVarArr2[length] = aVar;
            if (this.f3689f.compareAndSet(aVarArr, aVarArr2)) {
                z = true;
                break;
            }
        }
        if (z) {
            if (aVar.get()) {
                D(aVar);
            }
        } else {
            Throwable th = this.f3690g;
            if (th != null) {
                nVar.a(th);
            } else {
                nVar.onComplete();
            }
        }
    }
}