package d.a.w;

import d.a.l;
import java.util.Objects;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;

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

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public static final C0083a[] f5935c = new C0083a[0];

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final AtomicReference<C0083a<T>[]> f5936d = new AtomicReference<>(f5935c);

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

    /* JADX INFO: renamed from: d.a.w.a$a, reason: collision with other inner class name */
    public static final class C0083a<T> extends AtomicBoolean implements d.a.p.b {

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

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

        public C0083a(l<? super T> lVar, a<T> aVar) {
            this.f5938b = lVar;
            this.f5939c = aVar;
        }

        @Override // d.a.p.b
        public void dispose() {
            if (compareAndSet(false, true)) {
                this.f5939c.s(this);
            }
        }

        @Override // d.a.p.b
        public boolean isDisposed() {
            return get();
        }
    }

    @Override // d.a.l
    public void a(Throwable th) {
        Objects.requireNonNull(th, "onError called with null. Null values are generally not allowed in 2.x operators and sources.");
        C0083a<T>[] c0083aArr = this.f5936d.get();
        C0083a<T>[] c0083aArr2 = f5934b;
        if (c0083aArr == c0083aArr2) {
            d.a.u.a.w(th);
            return;
        }
        this.f5937e = th;
        for (C0083a<T> c0083a : this.f5936d.getAndSet(c0083aArr2)) {
            if (c0083a.get()) {
                d.a.u.a.w(th);
            } else {
                c0083a.f5938b.a(th);
            }
        }
    }

    @Override // d.a.l
    public void b() {
        C0083a<T>[] c0083aArr = this.f5936d.get();
        C0083a<T>[] c0083aArr2 = f5934b;
        if (c0083aArr == c0083aArr2) {
            return;
        }
        for (C0083a<T> c0083a : this.f5936d.getAndSet(c0083aArr2)) {
            if (!c0083a.get()) {
                c0083a.f5938b.b();
            }
        }
    }

    @Override // d.a.l
    public void c(d.a.p.b bVar) {
        if (this.f5936d.get() == f5934b) {
            bVar.dispose();
        }
    }

    @Override // d.a.l
    public void d(T t) {
        Objects.requireNonNull(t, "onNext called with null. Null values are generally not allowed in 2.x operators and sources.");
        for (C0083a<T> c0083a : this.f5936d.get()) {
            if (!c0083a.get()) {
                c0083a.f5938b.d(t);
            }
        }
    }

    @Override // d.a.h
    public void o(l<? super T> lVar) {
        boolean z;
        C0083a<T> c0083a = new C0083a<>(lVar, this);
        lVar.c(c0083a);
        while (true) {
            C0083a<T>[] c0083aArr = this.f5936d.get();
            z = false;
            if (c0083aArr == f5934b) {
                break;
            }
            int length = c0083aArr.length;
            C0083a<T>[] c0083aArr2 = new C0083a[length + 1];
            System.arraycopy(c0083aArr, 0, c0083aArr2, 0, length);
            c0083aArr2[length] = c0083a;
            if (this.f5936d.compareAndSet(c0083aArr, c0083aArr2)) {
                z = true;
                break;
            }
        }
        if (z) {
            if (c0083a.get()) {
                s(c0083a);
            }
        } else {
            Throwable th = this.f5937e;
            if (th != null) {
                lVar.a(th);
            } else {
                lVar.b();
            }
        }
    }

    public void s(C0083a<T> c0083a) {
        C0083a<T>[] c0083aArr;
        C0083a<T>[] c0083aArr2;
        do {
            c0083aArr = this.f5936d.get();
            if (c0083aArr == f5934b || c0083aArr == f5935c) {
                return;
            }
            int length = c0083aArr.length;
            int i2 = 0;
            while (true) {
                if (i2 >= length) {
                    i2 = -1;
                    break;
                } else if (c0083aArr[i2] == c0083a) {
                    break;
                } else {
                    i2++;
                }
            }
            if (i2 < 0) {
                return;
            }
            if (length == 1) {
                c0083aArr2 = f5935c;
            } else {
                C0083a<T>[] c0083aArr3 = new C0083a[length - 1];
                System.arraycopy(c0083aArr, 0, c0083aArr3, 0, i2);
                System.arraycopy(c0083aArr, i2 + 1, c0083aArr3, i2, (length - i2) - 1);
                c0083aArr2 = c0083aArr3;
            }
        } while (!this.f5936d.compareAndSet(c0083aArr, c0083aArr2));
    }
}