package e.a.r;

import e.a.u.h.f;
import java.util.ArrayList;

/* JADX INFO: compiled from: CompositeDisposable.java */
/* JADX INFO: loaded from: classes.dex */
public final class a implements b, e.a.u.a.a {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    f<b> f3634b;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    volatile boolean f3635f;

    @Override // e.a.u.a.a
    public boolean a(b bVar) {
        e.a.u.b.b.d(bVar, "Disposable item is null");
        if (this.f3635f) {
            return false;
        }
        synchronized (this) {
            if (this.f3635f) {
                return false;
            }
            f<b> fVar = this.f3634b;
            if (fVar != null && fVar.e(bVar)) {
                return true;
            }
            return false;
        }
    }

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

    @Override // e.a.u.a.a
    public boolean c(b bVar) {
        e.a.u.b.b.d(bVar, "d is null");
        if (!this.f3635f) {
            synchronized (this) {
                if (!this.f3635f) {
                    f<b> fVar = this.f3634b;
                    if (fVar == null) {
                        fVar = new f<>();
                        this.f3634b = fVar;
                    }
                    fVar.a(bVar);
                    return true;
                }
            }
        }
        bVar.dispose();
        return false;
    }

    public void d() {
        if (this.f3635f) {
            return;
        }
        synchronized (this) {
            if (this.f3635f) {
                return;
            }
            f<b> fVar = this.f3634b;
            this.f3634b = null;
            e(fVar);
        }
    }

    @Override // e.a.r.b
    public void dispose() {
        if (this.f3635f) {
            return;
        }
        synchronized (this) {
            if (this.f3635f) {
                return;
            }
            this.f3635f = true;
            f<b> fVar = this.f3634b;
            this.f3634b = null;
            e(fVar);
        }
    }

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

    @Override // e.a.r.b
    public boolean isDisposed() {
        return this.f3635f;
    }
}