package e.a.w;

import e.a.b;
import e.a.e;
import e.a.f;
import e.a.h;
import e.a.m;
import e.a.n;
import e.a.o;
import e.a.t.c;
import e.a.t.d;
import java.util.concurrent.Callable;

/* JADX INFO: compiled from: RxJavaPlugins.java */
/* JADX INFO: loaded from: classes.dex */
public final class a {
    static volatile c<? super Throwable> a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    static volatile d<? super Runnable, ? extends Runnable> f3872b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    static volatile d<? super Callable<n>, ? extends n> f3873c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    static volatile d<? super Callable<n>, ? extends n> f3874d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    static volatile d<? super Callable<n>, ? extends n> f3875e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    static volatile d<? super Callable<n>, ? extends n> f3876f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    static volatile d<? super n, ? extends n> f3877g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    static volatile d<? super n, ? extends n> f3878h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    static volatile d<? super n, ? extends n> f3879i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    static volatile d<? super e, ? extends e> f3880j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    static volatile d<? super h, ? extends h> f3881k;
    static volatile d<? super f, ? extends f> l;
    static volatile d<? super o, ? extends o> m;
    static volatile d<? super b, ? extends b> n;
    static volatile e.a.t.b<? super h, ? super m, ? extends m> o;

    static <T, U, R> R a(e.a.t.b<T, U, R> bVar, T t, U u) {
        try {
            return bVar.apply(t, u);
        } catch (Throwable th) {
            throw e.a.u.h.c.c(th);
        }
    }

    static <T, R> R b(d<T, R> dVar, T t) {
        try {
            return dVar.apply(t);
        } catch (Throwable th) {
            throw e.a.u.h.c.c(th);
        }
    }

    static n c(d<? super Callable<n>, ? extends n> dVar, Callable<n> callable) {
        Object objB = b(dVar, callable);
        e.a.u.b.b.d(objB, "Scheduler Callable result can't be null");
        return (n) objB;
    }

    static n d(Callable<n> callable) {
        try {
            n nVarCall = callable.call();
            e.a.u.b.b.d(nVarCall, "Scheduler Callable result can't be null");
            return nVarCall;
        } catch (Throwable th) {
            throw e.a.u.h.c.c(th);
        }
    }

    public static n e(Callable<n> callable) {
        e.a.u.b.b.d(callable, "Scheduler Callable can't be null");
        d<? super Callable<n>, ? extends n> dVar = f3873c;
        return dVar == null ? d(callable) : c(dVar, callable);
    }

    public static n f(Callable<n> callable) {
        e.a.u.b.b.d(callable, "Scheduler Callable can't be null");
        d<? super Callable<n>, ? extends n> dVar = f3875e;
        return dVar == null ? d(callable) : c(dVar, callable);
    }

    public static n g(Callable<n> callable) {
        e.a.u.b.b.d(callable, "Scheduler Callable can't be null");
        d<? super Callable<n>, ? extends n> dVar = f3876f;
        return dVar == null ? d(callable) : c(dVar, callable);
    }

    public static n h(Callable<n> callable) {
        e.a.u.b.b.d(callable, "Scheduler Callable can't be null");
        d<? super Callable<n>, ? extends n> dVar = f3874d;
        return dVar == null ? d(callable) : c(dVar, callable);
    }

    static boolean i(Throwable th) {
        return (th instanceof e.a.s.c) || (th instanceof IllegalStateException) || (th instanceof NullPointerException) || (th instanceof IllegalArgumentException) || (th instanceof e.a.s.a);
    }

    public static b j(b bVar) {
        d<? super b, ? extends b> dVar = n;
        return dVar != null ? (b) b(dVar, bVar) : bVar;
    }

    public static <T> e<T> k(e<T> eVar) {
        d<? super e, ? extends e> dVar = f3880j;
        return dVar != null ? (e) b(dVar, eVar) : eVar;
    }

    public static <T> f<T> l(f<T> fVar) {
        d<? super f, ? extends f> dVar = l;
        return dVar != null ? (f) b(dVar, fVar) : fVar;
    }

    public static <T> h<T> m(h<T> hVar) {
        d<? super h, ? extends h> dVar = f3881k;
        return dVar != null ? (h) b(dVar, hVar) : hVar;
    }

    public static <T> o<T> n(o<T> oVar) {
        d<? super o, ? extends o> dVar = m;
        return dVar != null ? (o) b(dVar, oVar) : oVar;
    }

    public static n o(n nVar) {
        d<? super n, ? extends n> dVar = f3877g;
        return dVar == null ? nVar : (n) b(dVar, nVar);
    }

    public static void p(Throwable th) {
        c<? super Throwable> cVar = a;
        if (th == null) {
            th = new NullPointerException("onError called with null. Null values are generally not allowed in 2.x operators and sources.");
        } else if (!i(th)) {
            th = new e.a.s.e(th);
        }
        if (cVar != null) {
            try {
                cVar.accept(th);
                return;
            } catch (Throwable th2) {
                th2.printStackTrace();
                u(th2);
            }
        }
        th.printStackTrace();
        u(th);
    }

    public static n q(n nVar) {
        d<? super n, ? extends n> dVar = f3878h;
        return dVar == null ? nVar : (n) b(dVar, nVar);
    }

    public static n r(n nVar) {
        d<? super n, ? extends n> dVar = f3879i;
        return dVar == null ? nVar : (n) b(dVar, nVar);
    }

    public static Runnable s(Runnable runnable) {
        d<? super Runnable, ? extends Runnable> dVar = f3872b;
        return dVar == null ? runnable : (Runnable) b(dVar, runnable);
    }

    public static <T> m<? super T> t(h<T> hVar, m<? super T> mVar) {
        e.a.t.b<? super h, ? super m, ? extends m> bVar = o;
        return bVar != null ? (m) a(bVar, hVar, mVar) : mVar;
    }

    static void u(Throwable th) {
        Thread threadCurrentThread = Thread.currentThread();
        threadCurrentThread.getUncaughtExceptionHandler().uncaughtException(threadCurrentThread, th);
    }
}