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);
        }
    }
}