package o;

/* renamed from: o.fUu, reason: case insensitive filesystem */
/* loaded from: classes6.dex */
public final class C13242fUu<T> extends AbstractC13175fSw<T> {
    final T a;
    private fRZ d;
    final InterfaceC13189fTc<? extends T> e = null;

    public C13242fUu(fRZ frz, T t) {
        this.d = frz;
        this.a = t;
    }

    @Override // o.AbstractC13175fSw
    public final void e(InterfaceC13176fSx<? super T> interfaceC13176fSx) {
        this.d.e(new Sts(this, interfaceC13176fSx));
    }

    /* renamed from: o.fUu$Sts */
    /* loaded from: classes6.dex */
    final class Sts implements InterfaceC13154fSb {
        private final InterfaceC13176fSx<? super T> d;
        private C13242fUu e;

        Sts(C13242fUu c13242fUu, InterfaceC13176fSx<? super T> interfaceC13176fSx) {
            this.e = c13242fUu;
            this.d = interfaceC13176fSx;
        }

        @Override // o.InterfaceC13154fSb
        public final void onComplete() {
            InterfaceC13189fTc<? extends T> interfaceC13189fTc = this.e.e;
            T t = this.e.a;
            if (t == null) {
                this.d.onError(new NullPointerException("The value supplied is null"));
            } else {
                this.d.e(t);
            }
        }

        @Override // o.InterfaceC13154fSb
        public final void onError(Throwable th) {
            this.d.onError(th);
        }

        @Override // o.InterfaceC13154fSb
        public final void onSubscribe(fSJ fsj) {
            this.d.onSubscribe(fsj);
        }
    }
}