package kotlinx.coroutines.flow;

import kotlin.coroutines.Continuation;
import kotlin.coroutines.intrinsics.CoroutineSingletons;
import kotlin.jvm.functions.Function2;
import kotlinx.coroutines.flow.internal.AbortFlowException;

/* JADX INFO: loaded from: classes.dex */
public final class n implements g {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final /* synthetic */ Function2 f29410a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final /* synthetic */ g f29411b;

    public n(Function2 function2, g gVar) {
        this.f29410a = function2;
        this.f29411b = gVar;
    }

    /* JADX WARN: Removed duplicated region for block: B:27:0x0074  */
    /* JADX WARN: Removed duplicated region for block: B:29:0x0077  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    @Override // kotlinx.coroutines.flow.g
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object c(Object obj, Continuation continuation) {
        FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1 flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1;
        Object obj2;
        Object obj3;
        n nVar;
        if (continuation instanceof FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1) {
            flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1 = (FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1) continuation;
            int i10 = flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1.label = i10 - Integer.MIN_VALUE;
            } else {
                flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1 = new FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1(this, continuation);
            }
        }
        Object obj4 = flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1.label;
        boolean z10 = true;
        if (i11 == 0) {
            kotlin.a.d(obj4);
            flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1.L$0 = this;
            flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1.L$1 = obj;
            flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1.label = 1;
            Object objInvoke = this.f29410a.invoke(obj, flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1);
            if (objInvoke == coroutineSingletons) {
                return coroutineSingletons;
            }
            obj2 = objInvoke;
            obj3 = obj;
            nVar = this;
        } else {
            if (i11 != 1) {
                if (i11 != 2) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                nVar = (n) flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1.L$0;
                kotlin.a.d(obj4);
                if (z10) {
                    throw new AbortFlowException(nVar);
                }
                return kd.e.f29109a;
            }
            Object obj5 = flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1.L$1;
            n nVar2 = (n) flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1.L$0;
            kotlin.a.d(obj4);
            obj3 = obj5;
            nVar = nVar2;
            obj2 = obj4;
        }
        if (((Boolean) obj2).booleanValue()) {
            g gVar = nVar.f29411b;
            flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1.L$0 = nVar;
            flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1.L$1 = null;
            flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1.label = 2;
            if (gVar.c(obj3, flowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1) == coroutineSingletons) {
                return coroutineSingletons;
            }
        } else {
            z10 = false;
        }
        if (z10) {
        }
    }
}