35 lines
1.5 KiB
Java
35 lines
1.5 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import io.reactivex.rxjava3.exceptions.CompositeException;
|
||
|
|
import io.reactivex.rxjava3.exceptions.MissingBackpressureException;
|
||
|
|
import io.reactivex.rxjava3.exceptions.OnErrorNotImplementedException;
|
||
|
|
import io.reactivex.rxjava3.exceptions.QueueOverflowException;
|
||
|
|
import io.reactivex.rxjava3.exceptions.UndeliverableException;
|
||
|
|
import java.util.Objects;
|
||
|
|
|
||
|
|
/* renamed from: o.fZu, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes.dex */
|
||
|
|
public final class C13418fZu {
|
||
|
|
public static void c(Throwable th) {
|
||
|
|
if (th == null) {
|
||
|
|
th = fYR.c("onError called with a null Throwable.");
|
||
|
|
} else if (!a(th)) {
|
||
|
|
th = new UndeliverableException(th);
|
||
|
|
}
|
||
|
|
Thread currentThread = Thread.currentThread();
|
||
|
|
currentThread.getUncaughtExceptionHandler().uncaughtException(currentThread, th);
|
||
|
|
}
|
||
|
|
|
||
|
|
private static boolean a(Throwable th) {
|
||
|
|
return (th instanceof OnErrorNotImplementedException) || (th instanceof MissingBackpressureException) || (th instanceof QueueOverflowException) || (th instanceof IllegalStateException) || (th instanceof NullPointerException) || (th instanceof IllegalArgumentException) || (th instanceof CompositeException);
|
||
|
|
}
|
||
|
|
|
||
|
|
public static AbstractC13173fSu e(InterfaceC13189fTc<AbstractC13173fSu> interfaceC13189fTc) {
|
||
|
|
try {
|
||
|
|
return (AbstractC13173fSu) Objects.requireNonNull(interfaceC13189fTc.d(), "Scheduler Supplier result can't be null");
|
||
|
|
} catch (Throwable th) {
|
||
|
|
throw fYR.c(th);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|