package o;

import java.util.Objects;

/* loaded from: classes6.dex */
public final class fVC<T> extends AbstractC13163fSk<T> {
    private InterfaceC13189fTc<? extends InterfaceC13169fSq<? extends T>> a;

    public fVC(InterfaceC13189fTc<? extends InterfaceC13169fSq<? extends T>> interfaceC13189fTc) {
        this.a = interfaceC13189fTc;
    }

    @Override // o.AbstractC13163fSk
    public final void subscribeActual(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
        try {
            ((InterfaceC13169fSq) Objects.requireNonNull(this.a.d(), "The supplier returned a null ObservableSource")).subscribe(interfaceC13174fSv);
        } catch (Throwable th) {
            C13147fSI.c(th);
            EnumC13195fTi.a(th, interfaceC13174fSv);
        }
    }
}