package com.google.firebase.firestore;

import Y4.InterfaceC0843i;
import Y4.InterfaceC0844j;
import m3.AbstractC2467b;
import w4.C3137A;

/* JADX INFO: loaded from: classes3.dex */
public final class FirestoreKt$dataObjects$$inlined$map$2 implements InterfaceC0843i {
    final /* synthetic */ InterfaceC0843i $this_unsafeTransform$inlined;

    /* JADX INFO: renamed from: com.google.firebase.firestore.FirestoreKt$dataObjects$$inlined$map$2$2, reason: invalid class name */
    public static final class AnonymousClass2<T> implements InterfaceC0844j {
        final /* synthetic */ InterfaceC0844j $this_unsafeFlow;

        /* JADX INFO: renamed from: com.google.firebase.firestore.FirestoreKt$dataObjects$$inlined$map$2$2$1, reason: invalid class name */
        @C4.e(c = "com.google.firebase.firestore.FirestoreKt$dataObjects$$inlined$map$2$2", f = "Firestore.kt", l = {223}, m = "emit")
        public static final class AnonymousClass1 extends C4.c {
            Object L$0;
            int label;
            /* synthetic */ Object result;

            public AnonymousClass1(A4.d dVar) {
                super(dVar);
            }

            @Override // C4.a
            public final Object invokeSuspend(Object obj) {
                this.result = obj;
                this.label |= Integer.MIN_VALUE;
                return AnonymousClass2.this.emit(null, this);
            }
        }

        public AnonymousClass2(InterfaceC0844j interfaceC0844j) {
            this.$this_unsafeFlow = interfaceC0844j;
        }

        /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
        @Override // Y4.InterfaceC0844j
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final Object emit(Object obj, A4.d dVar) {
            AnonymousClass1 anonymousClass1;
            if (dVar instanceof AnonymousClass1) {
                anonymousClass1 = (AnonymousClass1) dVar;
                int i6 = anonymousClass1.label;
                if ((i6 & Integer.MIN_VALUE) != 0) {
                    anonymousClass1.label = i6 - Integer.MIN_VALUE;
                } else {
                    anonymousClass1 = new AnonymousClass1(dVar);
                }
            }
            Object obj2 = anonymousClass1.result;
            B4.a aVar = B4.a.f492a;
            int i7 = anonymousClass1.label;
            if (i7 != 0) {
                if (i7 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                AbstractC2467b.l(obj2);
                return C3137A.f25453a;
            }
            AbstractC2467b.l(obj2);
            kotlin.jvm.internal.o.m();
            throw null;
        }

        public final Object emit$$forInline(Object obj, A4.d dVar) {
            new AnonymousClass1(dVar);
            kotlin.jvm.internal.o.m();
            throw null;
        }
    }

    public FirestoreKt$dataObjects$$inlined$map$2(InterfaceC0843i interfaceC0843i) {
        this.$this_unsafeTransform$inlined = interfaceC0843i;
    }

    @Override // Y4.InterfaceC0843i
    public Object collect(InterfaceC0844j interfaceC0844j, A4.d dVar) {
        kotlin.jvm.internal.o.m();
        throw null;
    }

    public Object collect$$forInline(InterfaceC0844j interfaceC0844j, A4.d dVar) {
        new C4.c(dVar) { // from class: com.google.firebase.firestore.FirestoreKt$dataObjects$$inlined$map$2.1
            int label;
            /* synthetic */ Object result;

            @Override // C4.a
            public final Object invokeSuspend(Object obj) {
                this.result = obj;
                this.label |= Integer.MIN_VALUE;
                return FirestoreKt$dataObjects$$inlined$map$2.this.collect(null, this);
            }
        };
        kotlin.jvm.internal.o.m();
        throw null;
    }
}