package defpackage;

import androidx.media3.container.NalUnitUtil;
import defpackage.cs3;
import defpackage.dw7;
import defpackage.fx4;
import java.io.Serializable;
import java.util.NoSuchElementException;
import java.util.concurrent.CancellationException;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.ContinuationImpl;
import kotlin.coroutines.jvm.internal.SuspendLambda;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"h73", "j73", "p73", "s73", "t73", "z73", "q83", "r83", "i93", "s93", "oa3", "ab3", "fb3", "ec3", "kc3", "ce3", "pf3"}, d2 = {}, k = 4, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
public final class k63 {
    public static final up8 a(vp8 vp8Var) {
        return new pu7(vp8Var);
    }

    public static final o29 b(ig6 ig6Var) {
        return new qu7(ig6Var, null);
    }

    public static final j43 c(gr3 gr3Var) {
        return new tr0(gr3Var, ak2.a, -2, ug0.a);
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Serializable d(j43 j43Var, l43 l43Var, ContinuationImpl continuationImpl) throws Throwable {
        l93 l93Var;
        dw7.h hVar;
        fx4 fx4Var;
        CancellationException cancellationExceptionW;
        if (continuationImpl instanceof l93) {
            l93Var = (l93) continuationImpl;
            int i = l93Var.c;
            if ((i & Integer.MIN_VALUE) != 0) {
                l93Var.c = i - Integer.MIN_VALUE;
            } else {
                l93Var = new l93(continuationImpl);
            }
        }
        Object obj = l93Var.b;
        ck1 ck1Var = ck1.a;
        int i2 = l93Var.c;
        if (i2 == 0) {
            s38.b(obj);
            dw7.h hVar2 = new dw7.h();
            try {
                l43 n93Var = new n93(l43Var, hVar2);
                l93Var.a = hVar2;
                l93Var.c = 1;
                if (j43Var.collect(n93Var, l93Var) == ck1Var) {
                    return ck1Var;
                }
                return null;
            } catch (Throwable th) {
                th = th;
                hVar = hVar2;
            }
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            hVar = l93Var.a;
            try {
                s38.b(obj);
                return null;
            } catch (Throwable th2) {
                th = th2;
            }
        }
        Throwable th3 = (Throwable) hVar.a;
        if ((th3 != null && th3.equals(th)) || ((fx4Var = (fx4) l93Var.getB().cb(fx4.b.a)) != null && fx4Var.isCancelled() && (cancellationExceptionW = fx4Var.w()) != null && cancellationExceptionW.equals(th))) {
            throw th;
        }
        if (th3 == null) {
            return th;
        }
        if (th instanceof CancellationException) {
            cr2.a(th3, th);
            throw th3;
        }
        cr2.a(th, th3);
        throw th;
    }

    public static final j43 e(gr3 gr3Var) {
        return new wu0(gr3Var, ak2.a, -2, ug0.a);
    }

    public static final Object f(j43 j43Var, gr3 gr3Var, Continuation continuation) {
        int i = ab3.a;
        C0758za3 c0758za3 = new C0758za3(gr3Var, null);
        ug0 ug0Var = ug0.a;
        Object objCollect = cs3.a.a(new jv0(c0758za3, j43Var, ak2.a, -2, ug0Var), null, 0, ug0Var, 1).collect(dp6.a, continuation);
        ck1 ck1Var = ck1.a;
        e6a e6aVar = e6a.a;
        if (objCollect != ck1Var) {
            objCollect = e6aVar;
        }
        return objCollect == ck1Var ? objCollect : e6aVar;
    }

    public static final j43 g(up8 up8Var, long j) {
        if (j >= 0) {
            return j == 0 ? up8Var : new n43(new C0547f83(new r2(j), up8Var, null));
        }
        throw new IllegalArgumentException("Debounce timeout should not be negative");
    }

    public static final j43 h(j43 j43Var) {
        if (j43Var instanceof o29) {
            return j43Var;
        }
        boolean z = j43Var instanceof qd2;
        mb1 mb1Var = r83.b;
        return (z && ((qd2) j43Var).b == mb1Var) ? j43Var : new qd2(j43Var, mb1Var);
    }

    public static final Object i(j43 j43Var, l43 l43Var, ContinuationImpl continuationImpl) throws Throwable {
        if (l43Var instanceof wm9) {
            throw ((wm9) l43Var).a;
        }
        Object objCollect = j43Var.collect(l43Var, continuationImpl);
        return objCollect == ck1.a ? objCollect : e6a.a;
    }

    public static final Object j(l43 l43Var, bv7 bv7Var, SuspendLambda suspendLambda) {
        Object objA = j73.a(l43Var, bv7Var, true, suspendLambda);
        return objA == ck1.a ? objA : e6a.a;
    }

    /* JADX WARN: Removed duplicated region for block: B:32:0x006a  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object k(j43 j43Var, Continuation continuation) {
        jb3 jb3Var;
        dw7.h hVar;
        af e;
        gb3 gb3Var;
        if (continuation instanceof jb3) {
            jb3Var = (jb3) continuation;
            int i = jb3Var.d;
            if ((i & Integer.MIN_VALUE) != 0) {
                jb3Var.d = i - Integer.MIN_VALUE;
            } else {
                jb3Var = new jb3(continuation);
            }
        }
        Object obj = jb3Var.c;
        Object obj2 = ck1.a;
        int i2 = jb3Var.d;
        kg9 kg9Var = kq6.a;
        if (i2 == 0) {
            s38.b(obj);
            dw7.h hVar2 = new dw7.h();
            hVar2.a = kg9Var;
            gb3 gb3Var2 = new gb3(hVar2);
            try {
                jb3Var.a = hVar2;
                jb3Var.b = gb3Var2;
                jb3Var.d = 1;
                if (j43Var.collect(gb3Var2, jb3Var) == obj2) {
                    return obj2;
                }
                hVar = hVar2;
            } catch (af e2) {
                hVar = hVar2;
                e = e2;
                gb3Var = gb3Var2;
                if (e.a != gb3Var) {
                    throw e;
                }
            }
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            gb3Var = jb3Var.b;
            hVar = jb3Var.a;
            try {
                s38.b(obj);
            } catch (af e3) {
                e = e3;
                if (e.a != gb3Var) {
                }
            }
        }
        Object obj3 = hVar.a;
        if (obj3 != kg9Var) {
            return obj3;
        }
        throw new NoSuchElementException("Expected at least one element");
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:32:0x0081  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /* JADX WARN: Type inference failed for: r0v11 */
    /* JADX WARN: Type inference failed for: r0v12 */
    /* JADX WARN: Type inference failed for: r0v3 */
    /* JADX WARN: Type inference failed for: r0v4 */
    /* JADX WARN: Type inference failed for: r0v5 */
    /* JADX WARN: Type inference failed for: r0v6, types: [java.lang.Object] */
    /* JADX WARN: Type inference failed for: r0v8, types: [gr3] */
    /* JADX WARN: Type inference failed for: r6v0, types: [j43, o29] */
    /* JADX WARN: Type inference failed for: r7v0, types: [gr3] */
    /* JADX WARN: Type inference failed for: r7v5, types: [java.lang.StringBuilder] */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object l(o29 o29Var, gr3 gr3Var, ContinuationImpl continuationImpl) {
        kb3 kb3Var;
        ?? r0;
        dw7.h hVar;
        af e;
        ib3 ib3Var;
        ?? r02;
        if (continuationImpl instanceof kb3) {
            kb3Var = (kb3) continuationImpl;
            int i = kb3Var.e;
            if ((i & Integer.MIN_VALUE) != 0) {
                kb3Var.e = i - Integer.MIN_VALUE;
            } else {
                kb3Var = new kb3(continuationImpl);
            }
        }
        Object obj = kb3Var.d;
        ck1 ck1Var = ck1.a;
        int i2 = kb3Var.e;
        kg9 kg9Var = kq6.a;
        if (i2 == 0) {
            s38.b(obj);
            dw7.h hVar2 = new dw7.h();
            hVar2.a = kg9Var;
            ib3 ib3Var2 = new ib3(gr3Var, hVar2);
            try {
                kb3Var.a = (SuspendLambda) gr3Var;
                kb3Var.b = hVar2;
                kb3Var.c = ib3Var2;
                kb3Var.e = 1;
                if (o29Var.collect(ib3Var2, kb3Var) == ck1Var) {
                    return ck1Var;
                }
                r02 = gr3Var;
                hVar = hVar2;
            } catch (af e2) {
                r0 = gr3Var;
                hVar = hVar2;
                e = e2;
                ib3Var = ib3Var2;
                r02 = r0;
                if (e.a != ib3Var) {
                    throw e;
                }
            }
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            ib3Var = kb3Var.c;
            hVar = kb3Var.b;
            r0 = (gr3) kb3Var.a;
            try {
                s38.b(obj);
                r02 = r0;
            } catch (af e3) {
                e = e3;
                r02 = r0;
                if (e.a != ib3Var) {
                }
            }
        }
        Object obj2 = hVar.a;
        if (obj2 != kg9Var) {
            return obj2;
        }
        throw new NoSuchElementException("Expected at least one element matching the predicate " + r02);
    }

    /* JADX WARN: Removed duplicated region for block: B:29:0x005c  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static final Object m(j43 j43Var, gr3 gr3Var, ContinuationImpl continuationImpl) {
        pb3 pb3Var;
        dw7.h hVar;
        af e;
        nb3 nb3Var;
        if (continuationImpl instanceof pb3) {
            pb3Var = (pb3) continuationImpl;
            int i = pb3Var.d;
            if ((i & Integer.MIN_VALUE) != 0) {
                pb3Var.d = i - Integer.MIN_VALUE;
            } else {
                pb3Var = new pb3(continuationImpl);
            }
        }
        Object obj = pb3Var.c;
        Object obj2 = ck1.a;
        int i2 = pb3Var.d;
        if (i2 == 0) {
            s38.b(obj);
            dw7.h hVar2 = new dw7.h();
            nb3 nb3Var2 = new nb3(gr3Var, hVar2);
            try {
                pb3Var.a = hVar2;
                pb3Var.b = nb3Var2;
                pb3Var.d = 1;
                if (j43Var.collect(nb3Var2, pb3Var) == obj2) {
                    return obj2;
                }
                hVar = hVar2;
            } catch (af e2) {
                hVar = hVar2;
                e = e2;
                nb3Var = nb3Var2;
                if (e.a != nb3Var) {
                }
            }
        } else {
            if (i2 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            nb3Var = pb3Var.b;
            hVar = pb3Var.a;
            try {
                s38.b(obj);
            } catch (af e3) {
                e = e3;
                if (e.a != nb3Var) {
                    throw e;
                }
            }
        }
        return hVar.a;
    }

    public static final j43 n(gr3 gr3Var) {
        return new y98(gr3Var);
    }

    public static final j43 o(j43 j43Var, gj1 gj1Var) {
        if (gj1Var.cb(fx4.b.a) != null) {
            throw new IllegalArgumentException(("Flow context cannot contain job in it. Had " + gj1Var).toString());
        }
        if (gj1Var.equals(ak2.a)) {
            return j43Var;
        }
        if (j43Var instanceof cs3) {
            return cs3.a.a((cs3) j43Var, gj1Var, 0, null, 6);
        }
        if ((12 & 2) != 0) {
            gj1Var = ak2.a;
        }
        return new ev0(j43Var, gj1Var, (12 & 4) != 0 ? -3 : 0, (12 & 8) != 0 ? ug0.a : null);
    }

    public static final fx4 p(rd3 rd3Var, ak1 ak1Var) {
        return wj0.c(ak1Var, null, null, new o73(rd3Var, null), 3);
    }
}