package o;

/* loaded from: classes6.dex */
public final class fTQ<T> extends AbstractC13211fTy implements InterfaceC13174fSv<T> {
    private fSQ<? super T> b;

    public fTQ(InterfaceC13145fSF interfaceC13145fSF, fSQ<? super T> fsq, fSQ<? super Throwable> fsq2, fSP fsp) {
        super(interfaceC13145fSF, fsq2, fsp);
        this.b = fsq;
    }

    @Override // o.InterfaceC13174fSv
    public final void onNext(T t) {
        if (get() != EnumC13192fTf.DISPOSED) {
            try {
                this.b.c(t);
            } catch (Throwable th) {
                C13147fSI.c(th);
                get().dispose();
                onError(th);
            }
        }
    }
}