package o; import java.util.Objects; import java.util.concurrent.Callable; /* renamed from: o.fSw, reason: case insensitive filesystem */ /* loaded from: classes.dex */ public abstract class AbstractC13175fSw implements fSD { protected abstract void e(InterfaceC13176fSx interfaceC13176fSx); public static AbstractC13175fSw d(fSB fsb) { Objects.requireNonNull(fsb, "source is null"); return new fXY(fsb); } public static AbstractC13175fSw e(Throwable th) { Objects.requireNonNull(th, "throwable is null"); InterfaceC13189fTc a = C13194fTh.a(th); Objects.requireNonNull(a, "supplier is null"); return new C13368fYg(a); } public static AbstractC13175fSw d(Callable callable) { Objects.requireNonNull(callable, "callable is null"); return new C13365fYd(callable); } public static AbstractC13175fSw e(InterfaceC13169fSq interfaceC13169fSq) { Objects.requireNonNull(interfaceC13169fSq, "observable is null"); return new C13333fXg(interfaceC13169fSq, null); } public static AbstractC13175fSw d(T t) { Objects.requireNonNull(t, "item is null"); return new C13370fYi(t); } public static AbstractC13175fSw c(fSD fsd) { Objects.requireNonNull(fsd, "source is null"); if (fsd instanceof AbstractC13175fSw) { return (AbstractC13175fSw) fsd; } return new C13373fYl(fsd); } public static AbstractC13175fSw e(fSD fsd, fSD fsd2, fSL fsl) { Objects.requireNonNull(fsd, "source1 is null"); Objects.requireNonNull(fsd2, "source2 is null"); Objects.requireNonNull(fsl, "zipper is null"); fSS b = C13194fTh.b(fsl); Objects.requireNonNull(b, "zipper is null"); return new C13375fYn(new fSD[]{fsd, fsd2}, b); } public final fSJ b(fSQ fsq, fSQ fsq2) { Objects.requireNonNull(fsq, "onSuccess is null"); Objects.requireNonNull(fsq2, "onError is null"); fTN ftn = new fTN(fsq, fsq2); c(ftn); return ftn; } @Override // o.fSD public final void c(InterfaceC13176fSx interfaceC13176fSx) { Objects.requireNonNull(interfaceC13176fSx, "observer is null"); Objects.requireNonNull(interfaceC13176fSx, "The RxJavaPlugins.onSubscribe hook returned a null SingleObserver. Please check the handler provided to RxJavaPlugins.setOnSingleSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins"); try { e(interfaceC13176fSx); } catch (NullPointerException e) { throw e; } catch (Throwable th) { C13147fSI.c(th); NullPointerException nullPointerException = new NullPointerException("subscribeActual failed"); nullPointerException.initCause(th); throw nullPointerException; } } }