package kotlinx.coroutines.flow;

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

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

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final /* synthetic */ sd.p f29402b;

    public j(androidx.datastore.core.l lVar, sd.p pVar) {
        this.f29401a = lVar;
        this.f29402b = pVar;
    }

    /* JADX WARN: Removed duplicated region for block: B:34:0x007c A[RETURN] */
    /* JADX WARN: Removed duplicated region for block: B:35:0x007d  */
    /* JADX WARN: Removed duplicated region for block: B:46:0x00a1 A[RETURN] */
    /* JADX WARN: Removed duplicated region for block: B:56:? A[RETURN, SYNTHETIC] */
    /* 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$onCompletion$$inlined$unsafeFlow$1$1 flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1;
        j jVar;
        x xVar;
        sd.p pVar;
        SafeCollector safeCollector;
        Throwable th;
        SafeCollector safeCollector2;
        sd.p pVar2;
        if (continuation instanceof FlowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1) {
            flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1 = (FlowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1) continuation;
            int i10 = flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.label;
            if ((i10 & Integer.MIN_VALUE) != 0) {
                flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.label = i10 - Integer.MIN_VALUE;
            } else {
                flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1 = new FlowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1(this, continuation);
            }
        }
        Object obj = flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.result;
        CoroutineSingletons coroutineSingletons = CoroutineSingletons.f29226a;
        int i11 = flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.label;
        if (i11 != 0) {
            if (i11 != 1) {
                if (i11 == 2) {
                    Throwable th2 = (Throwable) flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$0;
                    kotlin.a.d(obj);
                    throw th2;
                }
                if (i11 != 3) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                safeCollector2 = (SafeCollector) flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$0;
                try {
                    kotlin.a.d(obj);
                    safeCollector2.releaseIntercepted();
                    return kd.e.f29109a;
                } catch (Throwable th3) {
                    th = th3;
                    safeCollector2.releaseIntercepted();
                    throw th;
                }
            }
            gVar = (g) flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$1;
            jVar = (j) flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$0;
            try {
                kotlin.a.d(obj);
                safeCollector = new SafeCollector(gVar, flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.getContext());
                try {
                    pVar2 = jVar.f29402b;
                    flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$0 = safeCollector;
                    flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$1 = null;
                    flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.label = 3;
                    if (pVar2.a(safeCollector, null, flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1) != coroutineSingletons) {
                        return coroutineSingletons;
                    }
                    safeCollector2 = safeCollector;
                    safeCollector2.releaseIntercepted();
                    return kd.e.f29109a;
                } catch (Throwable th4) {
                    th = th4;
                    safeCollector2 = safeCollector;
                    safeCollector2.releaseIntercepted();
                    throw th;
                }
            } catch (Throwable th5) {
                th = th5;
                xVar = new x(th);
                pVar = jVar.f29402b;
                flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$0 = th;
                flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$1 = null;
                flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.label = 2;
                if (h.a(xVar, pVar, th, flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1) != coroutineSingletons) {
                    return coroutineSingletons;
                }
                throw th;
            }
        }
        kotlin.a.d(obj);
        try {
            f fVar = this.f29401a;
            flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$0 = this;
            flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$1 = gVar;
            flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.label = 1;
            if (fVar.a(gVar, flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1) == coroutineSingletons) {
                return coroutineSingletons;
            }
            jVar = this;
            safeCollector = new SafeCollector(gVar, flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.getContext());
            pVar2 = jVar.f29402b;
            flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$0 = safeCollector;
            flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$1 = null;
            flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.label = 3;
            if (pVar2.a(safeCollector, null, flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1) != coroutineSingletons) {
            }
        } catch (Throwable th6) {
            th = th6;
            jVar = this;
            xVar = new x(th);
            pVar = jVar.f29402b;
            flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$0 = th;
            flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.L$1 = null;
            flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1.label = 2;
            if (h.a(xVar, pVar, th, flowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1$1) != coroutineSingletons) {
            }
        }
    }
}