package kotlinx.coroutines.flow; import com.google.android.gms.ads.RequestConfiguration; import com.vungle.ads.internal.protos.Sdk; import kotlin.Metadata; import kotlin.Unit; import kotlin.coroutines.Continuation; import kotlin.coroutines.intrinsics.IntrinsicsKt; import kotlin.coroutines.jvm.internal.ContinuationImpl; import kotlin.coroutines.jvm.internal.DebugMetadata; import kotlin.jvm.functions.Function2; import kotlin.jvm.internal.InlineMarker; import org.objectweb.asm.Opcodes; /* JADX INFO: Add missing generic type declarations: [R] */ /* compiled from: SafeCollector.common.kt */ @Metadata(d1 = {"\u0000\u0019\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003*\u0001\u0000\b\n\u0018\u00002\b\u0012\u0004\u0012\u00028\u00000\u0001J\u001f\u0010\u0002\u001a\u00020\u00032\f\u0010\u0004\u001a\b\u0012\u0004\u0012\u00028\u00000\u0005H\u0096@ø\u0001\u0000¢\u0006\u0002\u0010\u0006\u0082\u0002\u0004\n\u0002\b\u0019¨\u0006\u0007¸\u0006\b"}, d2 = {"kotlinx/coroutines/flow/internal/SafeCollector_commonKt$unsafeFlow$1", "Lkotlinx/coroutines/flow/Flow;", "collect", "", "collector", "Lkotlinx/coroutines/flow/FlowCollector;", "(Lkotlinx/coroutines/flow/FlowCollector;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "kotlinx-coroutines-core", "kotlinx/coroutines/flow/FlowKt__EmittersKt$unsafeTransform$$inlined$unsafeFlow$1"}, k = 1, mv = {1, 8, 0}, xi = Opcodes.ARETURN) /* loaded from: classes7.dex */ public final class FlowKt__TransformKt$map$$inlined$unsafeTransform$1 implements Flow { final /* synthetic */ Flow $this_unsafeTransform$inlined; final /* synthetic */ Function2 $transform$inlined$1; /* compiled from: Emitters.kt */ @Metadata(d1 = {"\u0000\n\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0006\u0010\u0000\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u0002\"\u0004\b\u0001\u0010\u00032\u0006\u0010\u0004\u001a\u0002H\u0002H\u008a@¢\u0006\u0004\b\u0005\u0010\u0006¨\u0006\u0007"}, d2 = {"", "", RequestConfiguration.MAX_AD_CONTENT_RATING_T, "R", "value", "emit", "(Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "kotlinx/coroutines/flow/FlowKt__EmittersKt$unsafeTransform$1$1"}, k = 3, mv = {1, 8, 0}, xi = Opcodes.ARETURN) /* renamed from: kotlinx.coroutines.flow.FlowKt__TransformKt$map$$inlined$unsafeTransform$1$2 reason: invalid class name */ /* loaded from: classes7.dex */ public static final class AnonymousClass2 implements FlowCollector { final /* synthetic */ FlowCollector $this_unsafeFlow; final /* synthetic */ Function2 $transform$inlined; /* compiled from: Emitters.kt */ @Metadata(k = 3, mv = {1, 8, 0}, xi = Opcodes.ARETURN) @DebugMetadata(c = "kotlinx.coroutines.flow.FlowKt__TransformKt$map$$inlined$unsafeTransform$1$2", f = "Transform.kt", i = {}, l = {Sdk.SDKError.Reason.STALE_CACHED_RESPONSE_VALUE, Sdk.SDKError.Reason.STALE_CACHED_RESPONSE_VALUE}, m = "emit", n = {}, s = {}) /* renamed from: kotlinx.coroutines.flow.FlowKt__TransformKt$map$$inlined$unsafeTransform$1$2$1 reason: invalid class name */ /* loaded from: classes7.dex */ public static final class AnonymousClass1 extends ContinuationImpl { Object L$0; int label; /* synthetic */ Object result; public AnonymousClass1(Continuation continuation) { super(continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { this.result = obj; this.label |= Integer.MIN_VALUE; return AnonymousClass2.this.emit(null, this); } } public AnonymousClass2(FlowCollector flowCollector, Function2 function2) { this.$this_unsafeFlow = flowCollector; this.$transform$inlined = function2; } /* JADX WARN: Removed duplicated region for block: B:10:0x0025 */ /* JADX WARN: Removed duplicated region for block: B:16:0x003d */ /* JADX WARN: Removed duplicated region for block: B:22:0x0060 A[RETURN] */ @Override // kotlinx.coroutines.flow.FlowCollector /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final java.lang.Object emit(T r7, kotlin.coroutines.Continuation r8) { /* r6 = this; boolean r0 = r8 instanceof kotlinx.coroutines.flow.FlowKt__TransformKt$map$$inlined$unsafeTransform$1.AnonymousClass2.AnonymousClass1 if (r0 == 0) goto L14 r0 = r8 kotlinx.coroutines.flow.FlowKt__TransformKt$map$$inlined$unsafeTransform$1$2$1 r0 = (kotlinx.coroutines.flow.FlowKt__TransformKt$map$$inlined$unsafeTransform$1.AnonymousClass2.AnonymousClass1) r0 int r1 = r0.label r2 = -2147483648(0xffffffff80000000, float:-0.0) r1 = r1 & r2 if (r1 == 0) goto L14 int r8 = r0.label int r8 = r8 - r2 r0.label = r8 goto L19 L14: kotlinx.coroutines.flow.FlowKt__TransformKt$map$$inlined$unsafeTransform$1$2$1 r0 = new kotlinx.coroutines.flow.FlowKt__TransformKt$map$$inlined$unsafeTransform$1$2$1 r0.(r8) L19: java.lang.Object r8 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 2 r4 = 1 if (r2 == 0) goto L3d if (r2 == r4) goto L35 if (r2 != r3) goto L2d kotlin.ResultKt.throwOnFailure(r8) goto L61 L2d: java.lang.IllegalStateException r7 = new java.lang.IllegalStateException java.lang.String r8 = "call to 'resume' before 'invoke' with coroutine" r7.(r8) throw r7 L35: java.lang.Object r7 = r0.L$0 kotlinx.coroutines.flow.FlowCollector r7 = (kotlinx.coroutines.flow.FlowCollector) r7 kotlin.ResultKt.throwOnFailure(r8) goto L55 L3d: kotlin.ResultKt.throwOnFailure(r8) kotlinx.coroutines.flow.FlowCollector r8 = r6.$this_unsafeFlow r2 = r0 kotlin.coroutines.Continuation r2 = (kotlin.coroutines.Continuation) r2 kotlin.jvm.functions.Function2 r2 = r6.$transform$inlined r0.L$0 = r8 r0.label = r4 java.lang.Object r7 = r2.invoke(r7, r0) if (r7 != r1) goto L52 return r1 L52: r5 = r8 r8 = r7 r7 = r5 L55: r2 = 0 r0.L$0 = r2 r0.label = r3 java.lang.Object r7 = r7.emit(r8, r0) if (r7 != r1) goto L61 return r1 L61: kotlin.Unit r7 = kotlin.Unit.INSTANCE return r7 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.flow.FlowKt__TransformKt$map$$inlined$unsafeTransform$1.AnonymousClass2.emit(java.lang.Object, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Multi-variable type inference failed */ public final Object emit$$forInline(Object obj, Continuation continuation) { InlineMarker.mark(4); new AnonymousClass1(continuation); InlineMarker.mark(5); FlowCollector flowCollector = this.$this_unsafeFlow; Object invoke = this.$transform$inlined.invoke(obj, continuation); InlineMarker.mark(0); flowCollector.emit(invoke, continuation); InlineMarker.mark(1); return Unit.INSTANCE; } } public FlowKt__TransformKt$map$$inlined$unsafeTransform$1(Flow flow, Function2 function2) { this.$this_unsafeTransform$inlined = flow; this.$transform$inlined$1 = function2; } @Override // kotlinx.coroutines.flow.Flow public Object collect(FlowCollector flowCollector, Continuation continuation) { Object collect = this.$this_unsafeTransform$inlined.collect(new AnonymousClass2(flowCollector, this.$transform$inlined$1), continuation); return collect == IntrinsicsKt.getCOROUTINE_SUSPENDED() ? collect : Unit.INSTANCE; } public Object collect$$forInline(FlowCollector flowCollector, Continuation continuation) { InlineMarker.mark(4); new ContinuationImpl(continuation) { // from class: kotlinx.coroutines.flow.FlowKt__TransformKt$map$$inlined$unsafeTransform$1.1 int label; /* synthetic */ Object result; @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { this.result = obj; this.label |= Integer.MIN_VALUE; return FlowKt__TransformKt$map$$inlined$unsafeTransform$1.this.collect(null, this); } }; InlineMarker.mark(5); InlineMarker.mark(0); this.$this_unsafeTransform$inlined.collect(new AnonymousClass2(flowCollector, this.$transform$inlined$1), continuation); InlineMarker.mark(1); return Unit.INSTANCE; } }