package kotlinx.coroutines.flow;

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

/* JADX INFO: loaded from: classes.dex */
public final class k implements f {

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

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

    public k(Function2 function2, v vVar) {
        this.f29403a = function2;
        this.f29404b = vVar;
    }

    /* JADX WARN: Removed duplicated region for block: B:27:0x0078 A[RETURN] */
    /* 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) throws Throwable {
        FlowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1 flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1;
        Throwable th;
        SafeCollector safeCollector;
        k kVar;
        g gVar2;
        f fVar;
        if (continuation instanceof FlowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1) {
            flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1 = (FlowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1) continuation;
            int i10 = flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.label = i10 - Integer.MIN_VALUE;
            } else {
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1 = new FlowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1(this, continuation);
            }
        }
        Object obj = flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.label;
        if (i11 == 0) {
            kotlin.a.d(obj);
            SafeCollector safeCollector2 = new SafeCollector(gVar, flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.getContext());
            try {
                Function2 function2 = this.f29403a;
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.L$0 = this;
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.L$1 = gVar;
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.L$2 = safeCollector2;
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.label = 1;
                if (function2.invoke(safeCollector2, flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1) == coroutineSingletons) {
                    return coroutineSingletons;
                }
                kVar = this;
                gVar2 = gVar;
                safeCollector = safeCollector2;
                safeCollector.releaseIntercepted();
                fVar = kVar.f29404b;
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.L$0 = null;
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.L$1 = null;
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.L$2 = null;
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.label = 2;
                if (fVar.a(gVar2, flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1) == coroutineSingletons) {
                }
            } catch (Throwable th2) {
                th = th2;
                safeCollector = safeCollector2;
                safeCollector.releaseIntercepted();
                throw th;
            }
        } else if (i11 == 1) {
            safeCollector = (SafeCollector) flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.L$2;
            gVar2 = (g) flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.L$1;
            kVar = (k) flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.L$0;
            try {
                kotlin.a.d(obj);
                safeCollector.releaseIntercepted();
                fVar = kVar.f29404b;
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.L$0 = null;
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.L$1 = null;
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.L$2 = null;
                flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1.label = 2;
                if (fVar.a(gVar2, flowKt__EmittersKt$onStart$$inlined$unsafeFlow$1$1) == coroutineSingletons) {
                    return coroutineSingletons;
                }
            } catch (Throwable th3) {
                th = th3;
                safeCollector.releaseIntercepted();
                throw th;
            }
        } else {
            if (i11 != 2) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            kotlin.a.d(obj);
        }
        return kd.e.f29109a;
    }
}