package kotlinx.coroutines.flow; import kotlin.Metadata; import kotlin.coroutines.Continuation; import kotlin.coroutines.jvm.internal.ContinuationImpl; import kotlin.coroutines.jvm.internal.DebugMetadata; import kotlin.jvm.functions.Function2; import org.objectweb.asm.Opcodes; /* JADX INFO: Add missing generic type declarations: [T] */ /* compiled from: Limit.kt */ @Metadata(d1 = {"\u0000\u0013\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0003*\u0001\u0000\b\n\u0018\u00002\b\u0012\u0004\u0012\u00028\u00000\u0001J\u0019\u0010\u0002\u001a\u00020\u00032\u0006\u0010\u0004\u001a\u00028\u0000H\u0096@ø\u0001\u0000¢\u0006\u0002\u0010\u0005\u0082\u0002\u0004\n\u0002\b\u0019¨\u0006\u0006¸\u0006\u0000"}, d2 = {"kotlinx/coroutines/flow/FlowKt__LimitKt$collectWhile$collector$1", "Lkotlinx/coroutines/flow/FlowCollector;", "emit", "", "value", "(Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "kotlinx-coroutines-core"}, k = 1, mv = {1, 8, 0}, xi = 48) /* loaded from: classes7.dex */ public final class FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1 implements FlowCollector { final /* synthetic */ Function2 $predicate$inlined; final /* synthetic */ FlowCollector $this_unsafeFlow$inlined; /* compiled from: Limit.kt */ @Metadata(k = 3, mv = {1, 8, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.flow.FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1", f = "Limit.kt", i = {0, 0, 1}, l = {Opcodes.D2I, Opcodes.D2L}, m = "emit", n = {"this", "value", "this"}, s = {"L$0", "L$1", "L$0"}) /* renamed from: kotlinx.coroutines.flow.FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1 reason: invalid class name */ /* loaded from: classes7.dex */ public static final class AnonymousClass1 extends ContinuationImpl { Object L$0; Object L$1; 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 FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1.this.emit(null, this); } } public FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1(Function2 function2, FlowCollector flowCollector) { this.$predicate$inlined = function2; this.$this_unsafeFlow$inlined = flowCollector; } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:10:0x0025 */ /* JADX WARN: Removed duplicated region for block: B:16:0x0047 */ /* JADX WARN: Removed duplicated region for block: B:22:0x006f */ /* JADX WARN: Removed duplicated region for block: B:25:0x007f */ /* JADX WARN: Removed duplicated region for block: B:27:0x0082 */ /* JADX WARN: Removed duplicated region for block: B:29:0x0085 */ @Override // kotlinx.coroutines.flow.FlowCollector /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public java.lang.Object emit(T r8, kotlin.coroutines.Continuation r9) { /* r7 = this; boolean r0 = r9 instanceof kotlinx.coroutines.flow.FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1.AnonymousClass1 if (r0 == 0) goto L14 r0 = r9 kotlinx.coroutines.flow.FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1 r0 = (kotlinx.coroutines.flow.FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1.AnonymousClass1) r0 int r1 = r0.label r2 = -2147483648(0xffffffff80000000, float:-0.0) r1 = r1 & r2 if (r1 == 0) goto L14 int r9 = r0.label int r9 = r9 - r2 r0.label = r9 goto L19 L14: kotlinx.coroutines.flow.FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1 r0 = new kotlinx.coroutines.flow.FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1$1 r0.(r9) L19: java.lang.Object r9 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 2 r4 = 1 if (r2 == 0) goto L47 if (r2 == r4) goto L39 if (r2 != r3) goto L31 java.lang.Object r8 = r0.L$0 kotlinx.coroutines.flow.FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1 r8 = (kotlinx.coroutines.flow.FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1) r8 kotlin.ResultKt.throwOnFailure(r9) goto L80 L31: java.lang.IllegalStateException r8 = new java.lang.IllegalStateException java.lang.String r9 = "call to 'resume' before 'invoke' with coroutine" r8.(r9) throw r8 L39: java.lang.Object r8 = r0.L$1 java.lang.Object r2 = r0.L$0 kotlinx.coroutines.flow.FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1 r2 = (kotlinx.coroutines.flow.FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1) r2 kotlin.ResultKt.throwOnFailure(r9) r6 = r9 r9 = r8 r8 = r2 r2 = r6 goto L67 L47: kotlin.ResultKt.throwOnFailure(r9) r9 = r0 kotlin.coroutines.Continuation r9 = (kotlin.coroutines.Continuation) r9 kotlin.jvm.functions.Function2 r9 = r7.$predicate$inlined r0.L$0 = r7 r0.L$1 = r8 r0.label = r4 r2 = 6 kotlin.jvm.internal.InlineMarker.mark(r2) java.lang.Object r9 = r9.invoke(r8, r0) r2 = 7 kotlin.jvm.internal.InlineMarker.mark(r2) if (r9 != r1) goto L64 return r1 L64: r2 = r9 r9 = r8 r8 = r7 L67: java.lang.Boolean r2 = (java.lang.Boolean) r2 boolean r2 = r2.booleanValue() if (r2 == 0) goto L7f kotlinx.coroutines.flow.FlowCollector r2 = r8.$this_unsafeFlow$inlined r0.L$0 = r8 r5 = 0 r0.L$1 = r5 r0.label = r3 java.lang.Object r9 = r2.emit(r9, r0) if (r9 != r1) goto L80 return r1 L7f: r4 = 0 L80: if (r4 == 0) goto L85 kotlin.Unit r8 = kotlin.Unit.INSTANCE return r8 L85: kotlinx.coroutines.flow.internal.AbortFlowException r9 = new kotlinx.coroutines.flow.internal.AbortFlowException kotlinx.coroutines.flow.FlowCollector r8 = (kotlinx.coroutines.flow.FlowCollector) r8 r9.(r8) throw r9 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.flow.FlowKt__LimitKt$takeWhile$lambda$6$$inlined$collectWhile$1.emit(java.lang.Object, kotlin.coroutines.Continuation):java.lang.Object"); } }