package d.a.u;

import com.ifpdos.sdk.httpd.binder.aidl.RequestLine;
import com.seewo.vcommons.constants.Platform;
import d.a.m;
import e.f;
import e.o.d;
import e.o.h;
import e.p.b;
import e.s.b.l;
import e.s.c.i;
import e.t.c;
import g.s;
import i.a.a.a.b.e;
import j.b;
import j.b0;
import j.o;
import j.p;
import j.q;
import j.r;
import java.io.Closeable;
import java.io.IOException;
import java.io.PrintWriter;
import java.io.StringWriter;
import java.io.UnsupportedEncodingException;
import java.lang.reflect.InvocationTargetException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.NoSuchElementException;
import java.util.Objects;
import java.util.concurrent.Callable;
import kotlinx.coroutines.CancellableContinuation;
import kotlinx.coroutines.CancellableContinuationImpl;

/* JADX INFO: loaded from: classes.dex */
public final class a {
    /* JADX WARN: Removed duplicated region for block: B:18:0x0046 A[PHI: r0
      0x0046: PHI (r0v13 int) = (r0v3 int), (r0v33 int) binds: [B:17:0x0044, B:11:0x0035] A[DONT_GENERATE, DONT_INLINE]] */
    /* JADX WARN: Removed duplicated region for block: B:28:0x0069  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public static final e.r.c A(java.io.File r5) {
        /*
            Method dump skipped, instruction units count: 217
            To view this dump add '--comments-level debug' option
        */
        throw new UnsupportedOperationException("Method not decompiled: d.a.u.a.A(java.io.File):e.r.c");
    }

    public static final List<Integer> B(int[] iArr) {
        i.e(iArr, "$this$toList");
        int length = iArr.length;
        if (length == 0) {
            return h.f5956b;
        }
        if (length == 1) {
            return s(Integer.valueOf(iArr[0]));
        }
        i.e(iArr, "$this$toMutableList");
        ArrayList arrayList = new ArrayList(iArr.length);
        for (int i2 : iArr) {
            arrayList.add(Integer.valueOf(i2));
        }
        return arrayList;
    }

    public static final <T> List<T> C(T[] tArr) {
        i.e(tArr, "$this$toList");
        int length = tArr.length;
        if (length == 0) {
            return h.f5956b;
        }
        if (length == 1) {
            return s(tArr[0]);
        }
        i.e(tArr, "$this$toMutableList");
        i.e(tArr, "$this$asCollection");
        return new ArrayList(new d(tArr, false));
    }

    public static final int D(int i2, int i3) {
        return i.g(i2 ^ Integer.MIN_VALUE, i3 ^ Integer.MIN_VALUE);
    }

    public static void E(String str, boolean z, boolean z2) {
        int i2;
        try {
            int length = str.getBytes("UTF-8").length;
            boolean z3 = false;
            if (length < 1 || length > 65535) {
                throw new IllegalArgumentException(String.format("Invalid topic length, should be in range[%d, %d]!", 1, 65535));
            }
            if (!z) {
                if (!z2 && str.startsWith("$share/")) {
                    throw new IllegalArgumentException("Shared Subscriptions are not allowed.");
                }
                char[] charArray = "#+".toCharArray();
                if (!o(str)) {
                    if (!(charArray == null || charArray.length == 0)) {
                        int length2 = str.length();
                        int length3 = charArray.length;
                        int i3 = length2 - 1;
                        int i4 = length3 - 1;
                        loop3: for (int i5 = 0; i5 < length2; i5++) {
                            char cCharAt = str.charAt(i5);
                            for (int i6 = 0; i6 < length3; i6++) {
                                if (charArray[i6] == cCharAt && (!Character.isHighSurrogate(cCharAt) || i6 == i4 || (i5 < i3 && charArray[i6 + 1] == str.charAt(i5 + 1)))) {
                                    z3 = true;
                                    break loop3;
                                }
                            }
                        }
                    }
                }
                if (z3) {
                    throw new IllegalArgumentException("The topic name MUST NOT contain any wildcard characters (#+)");
                }
                return;
            }
            String[] strArr = {"#", "+"};
            boolean z4 = false;
            for (int i7 = 0; i7 < 2; i7++) {
                z4 = z4 || strArr[i7].equals(str);
            }
            if (z4) {
                return;
            }
            if (o(str) || o("#")) {
                i2 = 0;
            } else {
                int length4 = 0;
                i2 = 0;
                while (true) {
                    int iIndexOf = str.toString().indexOf("#".toString(), length4);
                    if (iIndexOf == -1) {
                        break;
                    }
                    i2++;
                    length4 = iIndexOf + "#".length();
                }
            }
            if (i2 > 1 || (str.contains("#") && !str.endsWith("/#"))) {
                throw new IllegalArgumentException("Invalid usage of multi-level wildcard in topic string: " + str);
            }
            char cCharAt2 = "+".charAt(0);
            char cCharAt3 = "/".charAt(0);
            char[] charArray2 = str.toCharArray();
            int length5 = charArray2.length;
            int i8 = 0;
            while (i8 < length5) {
                int i9 = i8 - 1;
                char c2 = i9 >= 0 ? charArray2[i9] : (char) 0;
                int i10 = i8 + 1;
                char c3 = i10 < length5 ? charArray2[i10] : (char) 0;
                if (charArray2[i8] == cCharAt2 && ((c2 != cCharAt3 && c2 != 0) || (c3 != cCharAt3 && c3 != 0))) {
                    throw new IllegalArgumentException(String.format("Invalid usage of single-level wildcard in topic string '%s'!", str));
                }
                i8 = i10;
            }
        } catch (UnsupportedEncodingException e2) {
            throw new IllegalStateException(e2.getMessage());
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public static final java.lang.Object F(java.lang.Exception r4, e.p.a<?> r5) throws java.lang.Exception {
        /*
            boolean r0 = r5 instanceof j.s
            if (r0 == 0) goto L13
            r0 = r5
            j.s r0 = (j.s) r0
            int r1 = r0.f6953f
            r2 = -2147483648(0xffffffff80000000, float:-0.0)
            r3 = r1 & r2
            if (r3 == 0) goto L13
            int r1 = r1 - r2
            r0.f6953f = r1
            goto L18
        L13:
            j.s r0 = new j.s
            r0.<init>(r5)
        L18:
            java.lang.Object r5 = r0.f6952e
            e.p.d.a r1 = e.p.d.a.COROUTINE_SUSPENDED
            int r2 = r0.f6953f
            r3 = 1
            if (r2 == 0) goto L38
            if (r2 != r3) goto L30
            java.lang.Object r4 = r0.f6954g
            java.lang.Exception r4 = (java.lang.Exception) r4
            boolean r0 = r5 instanceof e.f.a
            if (r0 == 0) goto L47
            e.f$a r5 = (e.f.a) r5
            java.lang.Throwable r4 = r5.f5931b
            throw r4
        L30:
            java.lang.IllegalStateException r4 = new java.lang.IllegalStateException
            java.lang.String r5 = "call to 'resume' before 'invoke' with coroutine"
            r4.<init>(r5)
            throw r4
        L38:
            boolean r2 = r5 instanceof e.f.a
            if (r2 != 0) goto L48
            r0.f6954g = r4
            r0.f6953f = r3
            java.lang.Object r5 = kotlinx.coroutines.YieldKt.yield(r0)
            if (r5 != r1) goto L47
            return r1
        L47:
            throw r4
        L48:
            e.f$a r5 = (e.f.a) r5
            java.lang.Throwable r4 = r5.f5931b
            throw r4
        */
        throw new UnsupportedOperationException("Method not decompiled: d.a.u.a.F(java.lang.Exception, e.p.a):java.lang.Object");
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Type inference failed for: r2v0, types: [T, java.lang.Object] */
    /* JADX WARN: Type inference failed for: r2v5 */
    /* JADX WARN: Type inference failed for: r2v7, types: [java.lang.Object] */
    public static final <T> void a(Appendable appendable, T t, l<? super T, ? extends CharSequence> lVar) throws IOException {
        CharSequence charSequenceValueOf;
        i.e(appendable, "$this$appendElement");
        if (lVar == null) {
            if (!(t != 0 ? t instanceof CharSequence : true)) {
                if (t instanceof Character) {
                    appendable.append(((Character) t).charValue());
                    return;
                }
                charSequenceValueOf = String.valueOf((Object) t);
            }
            appendable.append(charSequenceValueOf);
        }
        t = (T) lVar.e(t);
        charSequenceValueOf = (CharSequence) t;
        appendable.append(charSequenceValueOf);
    }

    public static final <T> Object b(b<T> bVar, e.p.a<? super T> aVar) {
        CancellableContinuation cancellableContinuationImpl = new CancellableContinuationImpl(n(aVar), 1);
        CancellableContinuation cancellableContinuation = cancellableContinuationImpl;
        cancellableContinuation.invokeOnCancellation(new o(bVar));
        bVar.B(new p(cancellableContinuation));
        Object result = cancellableContinuationImpl.getResult();
        if (result == e.p.d.a.COROUTINE_SUSPENDED) {
            i.e(aVar, "frame");
        }
        return result;
    }

    public static final <T> Object c(b<T> bVar, e.p.a<? super b0<T>> aVar) {
        CancellableContinuation cancellableContinuationImpl = new CancellableContinuationImpl(n(aVar), 1);
        CancellableContinuation cancellableContinuation = cancellableContinuationImpl;
        cancellableContinuation.invokeOnCancellation(new q(bVar));
        bVar.B(new r(cancellableContinuation));
        Object result = cancellableContinuationImpl.getResult();
        if (result == e.p.d.a.COROUTINE_SUSPENDED) {
            i.e(aVar, "frame");
        }
        return result;
    }

    public static m d(Callable<m> callable) {
        try {
            m mVarCall = callable.call();
            Objects.requireNonNull(mVarCall, "Scheduler Callable result can't be null");
            return mVarCall;
        } catch (Throwable th) {
            throw d.a.s.h.d.a(th);
        }
    }

    public static final int e(int i2) {
        if (2 <= i2 && 36 >= i2) {
            return i2;
        }
        StringBuilder sbD = a.b.c.a.a.D("radix ", i2, " was not in valid range ");
        sbD.append(new c(2, 36));
        throw new IllegalArgumentException(sbD.toString());
    }

    public static final void f(Closeable closeable, Throwable th) throws IllegalAccessException, IOException, InvocationTargetException {
        if (closeable == null) {
            return;
        }
        if (th == null) {
            closeable.close();
            return;
        }
        try {
            closeable.close();
        } catch (Throwable th2) {
            i.e(th, "$this$addSuppressed");
            i.e(th2, "exception");
            if (th != th2) {
                e.q.b.f5972a.a(th, th2);
            }
        }
    }

    public static final <T> int g(Iterable<? extends T> iterable, int i2) {
        i.e(iterable, "$this$collectionSizeOrDefault");
        return iterable instanceof Collection ? ((Collection) iterable).size() : i2;
    }

    public static final <T> boolean h(T[] tArr, T t) {
        int i2;
        i.e(tArr, "$this$contains");
        i.e(tArr, "$this$indexOf");
        if (t == null) {
            int length = tArr.length;
            i2 = 0;
            while (i2 < length) {
                if (tArr[i2] == null) {
                    break;
                }
                i2++;
            }
            i2 = -1;
        } else {
            int length2 = tArr.length;
            for (int i3 = 0; i3 < length2; i3++) {
                if (i.a(t, tArr[i3])) {
                    i2 = i3;
                    break;
                }
            }
            i2 = -1;
        }
        return i2 >= 0;
    }

    public static final Object i(Throwable th) {
        i.e(th, "exception");
        return new f.a(th);
    }

    public static i.a.a.a.b.a j(int i2) {
        return (i2 == 4 || i2 == 5) ? new e(i2) : new i.a.a.a.b.a(i2);
    }

    public static final boolean k(char c2, char c3, boolean z) {
        if (c2 == c3) {
            return true;
        }
        if (!z) {
            return false;
        }
        char upperCase = Character.toUpperCase(c2);
        char upperCase2 = Character.toUpperCase(c3);
        return upperCase == upperCase2 || Character.toLowerCase(upperCase) == Character.toLowerCase(upperCase2);
    }

    /* JADX WARN: Failed to restore switch over string. Please report as a decompilation issue */
    public static final <T> Class<T> l(e.u.b<T> bVar) {
        i.e(bVar, "$this$javaObjectType");
        Class<T> cls = (Class<T>) ((e.s.c.c) bVar).a();
        if (!cls.isPrimitive()) {
            return cls;
        }
        String name = cls.getName();
        switch (name.hashCode()) {
            case -1325958191:
                if (name.equals("double")) {
                }
                break;
            case 104431:
                if (name.equals("int")) {
                }
                break;
            case 3039496:
                if (name.equals("byte")) {
                }
                break;
            case 3052374:
                if (name.equals("char")) {
                }
                break;
            case 3327612:
                if (name.equals("long")) {
                }
                break;
            case 3625364:
                if (name.equals("void")) {
                }
                break;
            case 64711720:
                if (name.equals("boolean")) {
                }
                break;
            case 97526364:
                if (name.equals("float")) {
                }
                break;
            case 109413500:
                if (name.equals("short")) {
                }
                break;
        }
        return cls;
    }

    public static Class m(Class cls) {
        return cls == Boolean.TYPE ? Boolean.class : cls == Byte.TYPE ? Byte.class : cls == Character.TYPE ? Character.class : cls == Double.TYPE ? Double.class : cls == Float.TYPE ? Float.class : cls == Integer.TYPE ? Integer.class : cls == Long.TYPE ? Long.class : cls == Short.TYPE ? Short.class : cls;
    }

    public static final <T> e.p.a<T> n(e.p.a<? super T> aVar) {
        i.e(aVar, "$this$intercepted");
        e.p.e.a.c cVar = (e.p.e.a.c) (!(aVar instanceof e.p.e.a.c) ? null : aVar);
        if (cVar != null && (aVar = (e.p.a<T>) cVar.f5963c) == null) {
            e.p.c cVar2 = cVar.f5964d;
            i.c(cVar2);
            int i2 = e.p.b.f5959a;
            e.p.b bVar = (e.p.b) cVar2.c(b.a.f5960a);
            if (bVar == null || (aVar = (e.p.a<T>) bVar.b(cVar)) == null) {
                aVar = cVar;
            }
            cVar.f5963c = aVar;
        }
        return (e.p.a<T>) aVar;
    }

    public static boolean o(CharSequence charSequence) {
        return charSequence == null || charSequence.length() == 0;
    }

    public static final boolean p(char c2) {
        return Character.isWhitespace(c2) || Character.isSpaceChar(c2);
    }

    public static String q(byte[] bArr, CharSequence charSequence, CharSequence charSequence2, CharSequence charSequence3, int i2, CharSequence charSequence4, l lVar, int i3) {
        if ((i3 & 1) != 0) {
            charSequence = ", ";
        }
        CharSequence charSequence5 = (i3 & 2) != 0 ? "" : null;
        String str = (i3 & 4) == 0 ? null : "";
        if ((i3 & 8) != 0) {
            i2 = -1;
        }
        String str2 = (i3 & 16) != 0 ? "..." : null;
        if ((i3 & 32) != 0) {
            lVar = null;
        }
        i.e(bArr, "$this$joinToString");
        i.e(charSequence, "separator");
        i.e(charSequence5, "prefix");
        i.e(str, "postfix");
        i.e(str2, "truncated");
        StringBuilder sb = new StringBuilder();
        i.e(bArr, "$this$joinTo");
        i.e(sb, "buffer");
        i.e(charSequence, "separator");
        i.e(charSequence5, "prefix");
        i.e(str, "postfix");
        i.e(str2, "truncated");
        sb.append(charSequence5);
        int i4 = 0;
        for (byte b2 : bArr) {
            i4++;
            if (i4 > 1) {
                sb.append(charSequence);
            }
            if (i2 >= 0 && i4 > i2) {
                break;
            }
            sb.append(lVar != null ? (CharSequence) lVar.e(Byte.valueOf(b2)) : String.valueOf((int) b2));
        }
        if (i2 >= 0 && i4 > i2) {
            sb.append((CharSequence) str2);
        }
        sb.append((CharSequence) str);
        String string = sb.toString();
        i.d(string, "joinTo(StringBuilder(), …ed, transform).toString()");
        return string;
    }

    public static final <T> e.b<T> r(e.s.b.a<? extends T> aVar) {
        i.e(aVar, "initializer");
        return new e.h(aVar, null, 2);
    }

    public static final <T> List<T> s(T t) {
        List<T> listSingletonList = Collections.singletonList(t);
        i.d(listSingletonList, "java.util.Collections.singletonList(element)");
        return listSingletonList;
    }

    public static final int t(int i2) {
        return i2 < 0 ? i2 : i2 < 3 ? i2 + 1 : i2 < 1073741824 ? (int) ((i2 / 0.75f) + 1.0f) : Platform.UNKNOWN;
    }

    public static final int u(int i2, int i3) {
        int i4 = i2 % i3;
        return i4 >= 0 ? i4 : i4 + i3;
    }

    public static void v(Throwable th) {
        if (th == null) {
            th = new NullPointerException("onError called with null. Null values are generally not allowed in 2.x operators and sources.");
        } else {
            boolean z = true;
            if (!(th instanceof d.a.q.b) && !(th instanceof IllegalStateException) && !(th instanceof NullPointerException) && !(th instanceof IllegalArgumentException) && !(th instanceof d.a.q.a)) {
                z = false;
            }
            if (!z) {
                th = new d.a.q.d(th);
            }
        }
        th.printStackTrace();
        Thread threadCurrentThread = Thread.currentThread();
        threadCurrentThread.getUncaughtExceptionHandler().uncaughtException(threadCurrentThread, th);
    }

    public static boolean w(String str) {
        return (str.equals(RequestLine.METHOD_GET) || str.equals("HEAD")) ? false : true;
    }

    public static String x(s sVar) {
        String strF = sVar.f();
        String strH = sVar.h();
        if (strH == null) {
            return strF;
        }
        return strF + '?' + strH;
    }

    public static final char y(char[] cArr) {
        i.e(cArr, "$this$single");
        int length = cArr.length;
        if (length == 0) {
            throw new NoSuchElementException("Array is empty.");
        }
        if (length == 1) {
            return cArr[0];
        }
        throw new IllegalArgumentException("Array has more than one element.");
    }

    public static final String z(Throwable th) {
        i.e(th, "$this$stackTraceToString");
        StringWriter stringWriter = new StringWriter();
        PrintWriter printWriter = new PrintWriter(stringWriter);
        th.printStackTrace(printWriter);
        printWriter.flush();
        String string = stringWriter.toString();
        i.d(string, "sw.toString()");
        return string;
    }
}