package g.e.b.g0.f0;

import g.e.b.d0;
import g.e.b.e0;
import g.e.b.v;
import g.e.b.w;
import java.util.Objects;

/* JADX INFO: loaded from: classes.dex */
public final class o<T> extends d0<T> {
    public final w<T> a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final g.e.b.n<T> f4076b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final g.e.b.j f4077c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final g.e.b.h0.a<T> f4078d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final o<T>.b f4079e = new b(this, null);

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public volatile d0<T> f4080f;

    public final class b implements v, g.e.b.m {
        public b(o oVar, a aVar) {
        }
    }

    public o(w<T> wVar, g.e.b.n<T> nVar, g.e.b.j jVar, g.e.b.h0.a<T> aVar, e0 e0Var) {
        this.a = wVar;
        this.f4076b = nVar;
        this.f4077c = jVar;
        this.f4078d = aVar;
    }

    @Override // g.e.b.d0
    public T a(g.e.b.i0.a aVar) {
        if (this.f4076b == null) {
            d0<T> d0VarE = this.f4080f;
            if (d0VarE == null) {
                d0VarE = this.f4077c.e(null, this.f4078d);
                this.f4080f = d0VarE;
            }
            return d0VarE.a(aVar);
        }
        g.e.b.o oVarX = g.e.a.a.a.x(aVar);
        Objects.requireNonNull(oVarX);
        if (oVarX instanceof g.e.b.q) {
            return null;
        }
        return this.f4076b.a(oVarX, this.f4078d.f4166b, this.f4079e);
    }

    @Override // g.e.b.d0
    public void b(g.e.b.i0.c cVar, T t2) {
        w<T> wVar = this.a;
        if (wVar == null) {
            d0<T> d0VarE = this.f4080f;
            if (d0VarE == null) {
                d0VarE = this.f4077c.e(null, this.f4078d);
                this.f4080f = d0VarE;
            }
            d0VarE.b(cVar, t2);
            return;
        }
        if (t2 == null) {
            cVar.m();
        } else {
            q.V.b(cVar, wVar.a(t2, this.f4078d.f4166b, this.f4079e));
        }
    }
}