package kotlinx.coroutines.flow;

import kotlin.coroutines.Continuation;
import kotlin.coroutines.intrinsics.CoroutineSingletons;
import kotlin.jvm.functions.Function2;
import kotlin.jvm.internal.Ref$BooleanRef;

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

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final /* synthetic */ Ref$BooleanRef f29405a;

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

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

    public l(Ref$BooleanRef ref$BooleanRef, g gVar, Function2 function2) {
        this.f29405a = ref$BooleanRef;
        this.f29406b = gVar;
        this.f29407c = function2;
    }

    /* JADX WARN: Removed duplicated region for block: B:30:0x0072  */
    /* 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$dropWhile$1$1$emit$1 flowKt__LimitKt$dropWhile$1$1$emit$1;
        l lVar;
        if (continuation instanceof FlowKt__LimitKt$dropWhile$1$1$emit$1) {
            flowKt__LimitKt$dropWhile$1$1$emit$1 = (FlowKt__LimitKt$dropWhile$1$1$emit$1) continuation;
            int i10 = flowKt__LimitKt$dropWhile$1$1$emit$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                flowKt__LimitKt$dropWhile$1$1$emit$1.label = i10 - Integer.MIN_VALUE;
            } else {
                flowKt__LimitKt$dropWhile$1$1$emit$1 = new FlowKt__LimitKt$dropWhile$1$1$emit$1(this, continuation);
            }
        }
        Object objInvoke = flowKt__LimitKt$dropWhile$1$1$emit$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = flowKt__LimitKt$dropWhile$1$1$emit$1.label;
        kd.e eVar = kd.e.f29109a;
        if (i11 == 0) {
            kotlin.a.d(objInvoke);
            if (this.f29405a.element) {
                flowKt__LimitKt$dropWhile$1$1$emit$1.label = 1;
                return this.f29406b.c(obj, flowKt__LimitKt$dropWhile$1$1$emit$1) == coroutineSingletons ? coroutineSingletons : eVar;
            }
            flowKt__LimitKt$dropWhile$1$1$emit$1.L$0 = this;
            flowKt__LimitKt$dropWhile$1$1$emit$1.L$1 = obj;
            flowKt__LimitKt$dropWhile$1$1$emit$1.label = 2;
            objInvoke = this.f29407c.invoke(obj, flowKt__LimitKt$dropWhile$1$1$emit$1);
            if (objInvoke == coroutineSingletons) {
                return coroutineSingletons;
            }
            lVar = this;
            if (!((Boolean) objInvoke).booleanValue()) {
            }
        } else {
            if (i11 == 1) {
                kotlin.a.d(objInvoke);
            }
            if (i11 == 2) {
                obj = flowKt__LimitKt$dropWhile$1$1$emit$1.L$1;
                lVar = (l) flowKt__LimitKt$dropWhile$1$1$emit$1.L$0;
                kotlin.a.d(objInvoke);
                if (!((Boolean) objInvoke).booleanValue()) {
                    lVar.f29405a.element = true;
                    flowKt__LimitKt$dropWhile$1$1$emit$1.L$0 = null;
                    flowKt__LimitKt$dropWhile$1$1$emit$1.L$1 = null;
                    flowKt__LimitKt$dropWhile$1$1$emit$1.label = 3;
                    if (lVar.f29406b.c(obj, flowKt__LimitKt$dropWhile$1$1$emit$1) == coroutineSingletons) {
                        return coroutineSingletons;
                    }
                }
            } else {
                if (i11 != 3) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                kotlin.a.d(objInvoke);
            }
        }
        return eVar;
    }
}