79 lines
3.1 KiB
Java
79 lines
3.1 KiB
Java
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<T> implements fSD<T> {
|
|
protected abstract void e(InterfaceC13176fSx<? super T> interfaceC13176fSx);
|
|
|
|
public static <T> AbstractC13175fSw<T> d(fSB<T> fsb) {
|
|
Objects.requireNonNull(fsb, "source is null");
|
|
return new fXY(fsb);
|
|
}
|
|
|
|
public static <T> AbstractC13175fSw<T> 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 <T> AbstractC13175fSw<T> d(Callable<? extends T> callable) {
|
|
Objects.requireNonNull(callable, "callable is null");
|
|
return new C13365fYd(callable);
|
|
}
|
|
|
|
public static <T> AbstractC13175fSw<T> e(InterfaceC13169fSq<? extends T> interfaceC13169fSq) {
|
|
Objects.requireNonNull(interfaceC13169fSq, "observable is null");
|
|
return new C13333fXg(interfaceC13169fSq, null);
|
|
}
|
|
|
|
public static <T> AbstractC13175fSw<T> d(T t) {
|
|
Objects.requireNonNull(t, "item is null");
|
|
return new C13370fYi(t);
|
|
}
|
|
|
|
public static <T> AbstractC13175fSw<T> c(fSD<T> fsd) {
|
|
Objects.requireNonNull(fsd, "source is null");
|
|
if (fsd instanceof AbstractC13175fSw) {
|
|
return (AbstractC13175fSw) fsd;
|
|
}
|
|
return new C13373fYl(fsd);
|
|
}
|
|
|
|
public static <T1, T2, R> AbstractC13175fSw<R> e(fSD<? extends T1> fsd, fSD<? extends T2> fsd2, fSL<? super T1, ? super T2, ? extends R> 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<? super T> fsq, fSQ<? super Throwable> 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<? super T> 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;
|
|
}
|
|
}
|
|
}
|