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 m implements f {

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

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

    public m(Function2 function2, k kVar) {
        this.f29408a = kVar;
        this.f29409b = function2;
    }

    /* JADX WARN: Removed duplicated region for block: B:28:0x0055  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    @Override // kotlinx.coroutines.flow.f
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object a(g gVar, Continuation continuation) {
        FlowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1 flowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1;
        n nVar;
        if (continuation instanceof FlowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1) {
            flowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1 = (FlowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1) continuation;
            int i10 = flowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                flowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1.label = i10 - Integer.MIN_VALUE;
            } else {
                flowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1 = new FlowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1(this, continuation);
            }
        }
        Object obj = flowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = flowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1.label;
        if (i11 == 0) {
            kotlin.a.d(obj);
            f fVar = this.f29408a;
            n nVar2 = new n(this.f29409b, gVar);
            try {
                flowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1.L$0 = nVar2;
                flowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1.label = 1;
                if (fVar.a(nVar2, flowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1) == coroutineSingletons) {
                    return coroutineSingletons;
                }
            } catch (AbortFlowException e10) {
                e = e10;
                nVar = nVar2;
                if (e.f29378a != nVar) {
                    throw e;
                }
            }
        } else {
            if (i11 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            nVar = (n) flowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1$1.L$0;
            try {
                kotlin.a.d(obj);
            } catch (AbortFlowException e11) {
                e = e11;
                if (e.f29378a != nVar) {
                }
            }
        }
        return kd.e.f29109a;
    }
}