package i.a.k;

import java.util.ArrayList;

/* JADX INFO: compiled from: CompositeDisposable.java */
/* JADX INFO: loaded from: classes.dex */
public final class a implements b, i.a.n.a.a {
    i.a.n.h.e<b> b;
    volatile boolean d;

    @Override // i.a.n.a.a
    public boolean a(b bVar) {
        i.a.n.b.b.d(bVar, "Disposable item is null");
        if (this.d) {
            return false;
        }
        synchronized (this) {
            if (this.d) {
                return false;
            }
            i.a.n.h.e<b> eVar = this.b;
            if (eVar != null && eVar.e(bVar)) {
                return true;
            }
            return false;
        }
    }

    @Override // i.a.n.a.a
    public boolean b(b bVar) {
        if (!a(bVar)) {
            return false;
        }
        bVar.dispose();
        return true;
    }

    @Override // i.a.n.a.a
    public boolean c(b bVar) {
        i.a.n.b.b.d(bVar, "d is null");
        if (!this.d) {
            synchronized (this) {
                if (!this.d) {
                    i.a.n.h.e<b> eVar = this.b;
                    if (eVar == null) {
                        eVar = new i.a.n.h.e<>();
                        this.b = eVar;
                    }
                    eVar.a(bVar);
                    return true;
                }
            }
        }
        bVar.dispose();
        return false;
    }

    public void d() {
        if (this.d) {
            return;
        }
        synchronized (this) {
            if (this.d) {
                return;
            }
            i.a.n.h.e<b> eVar = this.b;
            this.b = null;
            e(eVar);
        }
    }

    @Override // i.a.k.b
    public void dispose() {
        if (this.d) {
            return;
        }
        synchronized (this) {
            if (this.d) {
                return;
            }
            this.d = true;
            i.a.n.h.e<b> eVar = this.b;
            this.b = null;
            e(eVar);
        }
    }

    void e(i.a.n.h.e<b> eVar) {
        if (eVar == null) {
            return;
        }
        ArrayList arrayList = null;
        for (Object obj : eVar.b()) {
            if (obj instanceof b) {
                try {
                    ((b) obj).dispose();
                } catch (Throwable th) {
                    i.a.l.b.b(th);
                    if (arrayList == null) {
                        arrayList = new ArrayList();
                    }
                    arrayList.add(th);
                }
            }
        }
        if (arrayList != null) {
            if (arrayList.size() != 1) {
                throw new i.a.l.a(arrayList);
            }
            throw i.a.n.h.c.c((Throwable) arrayList.get(0));
        }
    }

    @Override // i.a.k.b
    public boolean isDisposed() {
        return this.d;
    }
}