package kotlinx.coroutines.flow;

import kotlin.coroutines.Continuation;
import kotlin.coroutines.intrinsics.CoroutineSingletons;
import kotlin.jvm.functions.Function2;
import kotlinx.coroutines.channels.BufferOverflow;

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

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final Function2 f29363e;

    public b(Function2 function2, kotlin.coroutines.h hVar, int i10, BufferOverflow bufferOverflow) {
        super(function2, hVar, i10, bufferOverflow);
        this.f29363e = function2;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    @Override // kotlinx.coroutines.flow.internal.d
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object c(kotlinx.coroutines.channels.l lVar, Continuation continuation) {
        CallbackFlowBuilder$collectTo$1 callbackFlowBuilder$collectTo$1;
        if (continuation instanceof CallbackFlowBuilder$collectTo$1) {
            callbackFlowBuilder$collectTo$1 = (CallbackFlowBuilder$collectTo$1) continuation;
            int i10 = callbackFlowBuilder$collectTo$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                callbackFlowBuilder$collectTo$1.label = i10 - Integer.MIN_VALUE;
            } else {
                callbackFlowBuilder$collectTo$1 = new CallbackFlowBuilder$collectTo$1(this, continuation);
            }
        }
        Object obj = callbackFlowBuilder$collectTo$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = callbackFlowBuilder$collectTo$1.label;
        kd.e eVar = kd.e.f29109a;
        if (i11 == 0) {
            kotlin.a.d(obj);
            callbackFlowBuilder$collectTo$1.L$0 = lVar;
            callbackFlowBuilder$collectTo$1.label = 1;
            Object objInvoke = this.f29364d.invoke(lVar, callbackFlowBuilder$collectTo$1);
            if (objInvoke != coroutineSingletons) {
                objInvoke = eVar;
            }
            if (objInvoke == coroutineSingletons) {
                return coroutineSingletons;
            }
        } else {
            if (i11 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            lVar = (kotlinx.coroutines.channels.l) callbackFlowBuilder$collectTo$1.L$0;
            kotlin.a.d(obj);
        }
        if (((kotlinx.coroutines.channels.k) lVar).f29342d.j()) {
            return eVar;
        }
        throw new IllegalStateException("'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.");
    }

    @Override // kotlinx.coroutines.flow.internal.d
    public final kotlinx.coroutines.flow.internal.d d(kotlin.coroutines.h hVar, int i10, BufferOverflow bufferOverflow) {
        return new b(this.f29363e, hVar, i10, bufferOverflow);
    }
}