package o;

/* loaded from: classes6.dex */
public final class fVJ<T> extends fUX<T, T> {
    private fSQ<? super T> b;

    public fVJ(InterfaceC13169fSq<T> interfaceC13169fSq, fSQ<? super T> fsq) {
        super(interfaceC13169fSq);
        this.b = fsq;
    }

    @Override // o.AbstractC13163fSk
    public final void subscribeActual(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
        this.c.subscribe(new RVV(interfaceC13174fSv, this.b));
    }

    /* loaded from: classes6.dex */
    static final class RVV<T> extends fTA<T, T> {
        private fSQ<? super T> a;

        RVV(InterfaceC13174fSv<? super T> interfaceC13174fSv, fSQ<? super T> fsq) {
            super(interfaceC13174fSv);
            this.a = fsq;
        }

        @Override // o.InterfaceC13174fSv
        public final void onNext(T t) {
            this.d.onNext(t);
            if (this.b == 0) {
                try {
                    this.a.c(t);
                } catch (Throwable th) {
                    b(th);
                }
            }
        }

        @Override // o.InterfaceC13413fZp
        public final int b(int i) {
            return e(i);
        }

        @Override // o.InterfaceC13414fZq
        public final T b() throws Throwable {
            T b = this.e.b();
            if (b != null) {
                this.a.c(b);
            }
            return b;
        }
    }
}