package E4;

/* JADX INFO: loaded from: classes.dex */
public final class c extends F4.e {

    /* JADX INFO: renamed from: n, reason: collision with root package name */
    public final I0.k f509n;

    /* JADX INFO: renamed from: o, reason: collision with root package name */
    public final I0.k f510o;

    public c(I0.k kVar, h4.h hVar, int i, D4.a aVar) {
        super(hVar, i, aVar);
        this.f509n = kVar;
        this.f510o = kVar;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    @Override // F4.e
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct code enable 'Show inconsistent code' option in preferences
    */
    public final java.lang.Object a(D4.r r6, h4.c r7) throws java.lang.Throwable {
        /*
            r5 = this;
            boolean r0 = r7 instanceof E4.b
            if (r0 == 0) goto L13
            r0 = r7
            E4.b r0 = (E4.b) r0
            int r1 = r0.f508n
            r2 = -2147483648(0xffffffff80000000, float:-0.0)
            r3 = r1 & r2
            if (r3 == 0) goto L13
            int r1 = r1 - r2
            r0.f508n = r1
            goto L1a
        L13:
            E4.b r0 = new E4.b
            j4.c r7 = (j4.AbstractC0801c) r7
            r0.<init>(r5, r7)
        L1a:
            java.lang.Object r7 = r0.f506l
            i4.a r1 = i4.EnumC0643a.f6670k
            int r2 = r0.f508n
            d4.i r3 = d4.C0550i.f6143a
            r4 = 1
            if (r2 == 0) goto L35
            if (r2 != r4) goto L2d
            D4.r r6 = r0.f505k
            a.AbstractC0212a.H(r7)
            goto L49
        L2d:
            java.lang.IllegalStateException r6 = new java.lang.IllegalStateException
            java.lang.String r7 = "call to 'resume' before 'invoke' with coroutine"
            r6.<init>(r7)
            throw r6
        L35:
            a.AbstractC0212a.H(r7)
            r0.f505k = r6
            r0.f508n = r4
            I0.k r7 = r5.f509n
            java.lang.Object r7 = r7.invoke(r6, r0)
            if (r7 != r1) goto L45
            goto L46
        L45:
            r7 = r3
        L46:
            if (r7 != r1) goto L49
            return r1
        L49:
            D4.q r6 = (D4.q) r6
            D4.c r6 = r6.f490n
            boolean r6 = r6.s()
            if (r6 == 0) goto L54
            return r3
        L54:
            java.lang.IllegalStateException r6 = new java.lang.IllegalStateException
            java.lang.String r7 = "'awaitClose { yourCallbackOrListener.cancel() }' should be used in the end of callbackFlow block.\nOtherwise, a callback/listener may leak in case of external cancellation.\nSee callbackFlow API documentation for the details."
            r6.<init>(r7)
            throw r6
        */
        throw new UnsupportedOperationException("Method not decompiled: E4.c.a(D4.r, h4.c):java.lang.Object");
    }

    @Override // F4.e
    public final F4.e b(h4.h hVar, int i, D4.a aVar) {
        return new c(this.f510o, hVar, i, aVar);
    }

    @Override // F4.e
    public final String toString() {
        return "block[" + this.f509n + "] -> " + super.toString();
    }
}