package f.a.a0;

import f.a.n;
import f.a.w.h.a;

/* JADX INFO: compiled from: SerializedSubject.java */
/* JADX INFO: loaded from: classes.dex */
public final class c<T> extends d<T> implements a.InterfaceC0073a<Object> {

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

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

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public f.a.w.h.a<Object> f3695f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public volatile boolean f3696g;

    public c(d<T> dVar) {
        this.f3693b = dVar;
    }

    public void D() {
        f.a.w.h.a<Object> aVar;
        while (true) {
            synchronized (this) {
                aVar = this.f3695f;
                if (aVar == null) {
                    this.f3694e = false;
                    return;
                }
                this.f3695f = null;
            }
            aVar.b(this);
        }
    }

    @Override // f.a.n
    public void a(Throwable th) {
        if (this.f3696g) {
            f.a.y.a.C0(th);
            return;
        }
        synchronized (this) {
            boolean z = false;
            if (this.f3696g) {
                z = true;
            } else {
                this.f3696g = true;
                if (this.f3694e) {
                    f.a.w.h.a<Object> aVar = this.f3695f;
                    if (aVar == null) {
                        aVar = new f.a.w.h.a<>(4);
                        this.f3695f = aVar;
                    }
                    aVar.a[0] = f.a.w.h.d.error(th);
                    return;
                }
                this.f3694e = true;
            }
            if (z) {
                f.a.y.a.C0(th);
            } else {
                this.f3693b.a(th);
            }
        }
    }

    @Override // f.a.n
    public void b(f.a.t.b bVar) {
        boolean z = true;
        if (!this.f3696g) {
            synchronized (this) {
                if (!this.f3696g) {
                    if (this.f3694e) {
                        f.a.w.h.a<Object> aVar = this.f3695f;
                        if (aVar == null) {
                            aVar = new f.a.w.h.a<>(4);
                            this.f3695f = aVar;
                        }
                        aVar.a(f.a.w.h.d.disposable(bVar));
                        return;
                    }
                    this.f3694e = true;
                    z = false;
                }
            }
        }
        if (z) {
            bVar.dispose();
        } else {
            this.f3693b.b(bVar);
            D();
        }
    }

    @Override // f.a.n
    public void c(T t) {
        if (this.f3696g) {
            return;
        }
        synchronized (this) {
            if (this.f3696g) {
                return;
            }
            if (!this.f3694e) {
                this.f3694e = true;
                this.f3693b.c(t);
                D();
            } else {
                f.a.w.h.a<Object> aVar = this.f3695f;
                if (aVar == null) {
                    aVar = new f.a.w.h.a<>(4);
                    this.f3695f = aVar;
                }
                aVar.a(f.a.w.h.d.next(t));
            }
        }
    }

    @Override // f.a.n
    public void onComplete() {
        if (this.f3696g) {
            return;
        }
        synchronized (this) {
            if (this.f3696g) {
                return;
            }
            this.f3696g = true;
            if (!this.f3694e) {
                this.f3694e = true;
                this.f3693b.onComplete();
                return;
            }
            f.a.w.h.a<Object> aVar = this.f3695f;
            if (aVar == null) {
                aVar = new f.a.w.h.a<>(4);
                this.f3695f = aVar;
            }
            aVar.a(f.a.w.h.d.complete());
        }
    }

    @Override // f.a.w.h.a.InterfaceC0073a, f.a.v.e
    public boolean test(Object obj) {
        return f.a.w.h.d.acceptFull(obj, this.f3693b);
    }

    @Override // f.a.i
    public void v(n<? super T> nVar) {
        this.f3693b.d(nVar);
    }
}