package f.a.r;

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

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

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

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

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

    b(c<T> cVar) {
        this.b = cVar;
    }

    @Override // f.a.f
    public void a(Throwable th) {
        if (this.f948g) {
            f.a.p.a.m(th);
            return;
        }
        synchronized (this) {
            boolean z = true;
            if (!this.f948g) {
                this.f948g = true;
                if (this.f946e) {
                    f.a.n.h.a<Object> aVar = this.f947f;
                    if (aVar == null) {
                        aVar = new f.a.n.h.a<>(4);
                        this.f947f = aVar;
                    }
                    aVar.d(f.a.n.h.c.error(th));
                    return;
                }
                this.f946e = true;
                z = false;
            }
            if (z) {
                f.a.p.a.m(th);
            } else {
                this.b.a(th);
            }
        }
    }

    @Override // f.a.f
    public void b() {
        if (this.f948g) {
            return;
        }
        synchronized (this) {
            if (this.f948g) {
                return;
            }
            this.f948g = true;
            if (!this.f946e) {
                this.f946e = true;
                this.b.b();
                return;
            }
            f.a.n.h.a<Object> aVar = this.f947f;
            if (aVar == null) {
                aVar = new f.a.n.h.a<>(4);
                this.f947f = aVar;
            }
            aVar.b(f.a.n.h.c.complete());
        }
    }

    @Override // f.a.f
    public void c(f.a.k.b bVar) {
        boolean z = true;
        if (!this.f948g) {
            synchronized (this) {
                if (!this.f948g) {
                    if (this.f946e) {
                        f.a.n.h.a<Object> aVar = this.f947f;
                        if (aVar == null) {
                            aVar = new f.a.n.h.a<>(4);
                            this.f947f = aVar;
                        }
                        aVar.b(f.a.n.h.c.disposable(bVar));
                        return;
                    }
                    this.f946e = true;
                    z = false;
                }
            }
        }
        if (z) {
            bVar.dispose();
        } else {
            this.b.c(bVar);
            w();
        }
    }

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

    @Override // f.a.d
    protected void q(f<? super T> fVar) {
        this.b.e(fVar);
    }

    @Override // f.a.n.h.a.InterfaceC0054a
    public boolean test(Object obj) {
        return f.a.n.h.c.acceptFull(obj, this.b);
    }

    void w() {
        f.a.n.h.a<Object> aVar;
        while (true) {
            synchronized (this) {
                aVar = this.f947f;
                if (aVar == null) {
                    this.f946e = false;
                    return;
                }
                this.f947f = null;
            }
            aVar.c(this);
        }
    }
}