package kotlinx.coroutines.flow; import com.alibaba.fastjson.asm.Opcodes; import kotlin.Metadata; import kotlin.ResultKt; import kotlin.Unit; import kotlin.coroutines.Continuation; import kotlin.coroutines.intrinsics.IntrinsicsKt; import kotlin.coroutines.jvm.internal.DebugMetadata; import kotlin.coroutines.jvm.internal.SuspendLambda; import kotlin.jvm.functions.Function2; import kotlin.jvm.functions.Function3; import kotlin.jvm.internal.InlineMarker; /* JADX INFO: compiled from: Emitters.kt */ /* JADX INFO: loaded from: classes2.dex */ @Metadata(d1 = {"\u0000>\n\u0000\n\u0002\u0010\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0010\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\u001a\u0010\u0010\u0000\u001a\u00020\u0001*\u0006\u0012\u0002\b\u00030\u0002H\u0000\u001as\u0010\u0003\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u0004*\b\u0012\u0004\u0012\u0002H\u00040\u00022D\u0010\u0005\u001a@\b\u0001\u0012\n\u0012\b\u0012\u0004\u0012\u0002H\u00040\u0002\u0012\u0015\u0012\u0013\u0018\u00010\u0007¢\u0006\f\b\b\u0012\b\b\t\u0012\u0004\b\b(\n\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u00010\u000b\u0012\u0006\u0012\u0004\u0018\u00010\f0\u0006¢\u0006\u0002\b\r2\b\u0010\n\u001a\u0004\u0018\u00010\u0007H\u0082@ø\u0001\u0000¢\u0006\u0004\b\u000e\u0010\u000f\u001aj\u0010\u0010\u001a\b\u0012\u0004\u0012\u0002H\u00040\u0011\"\u0004\b\u0000\u0010\u0004*\b\u0012\u0004\u0012\u0002H\u00040\u00112D\u0010\u0005\u001a@\b\u0001\u0012\n\u0012\b\u0012\u0004\u0012\u0002H\u00040\u0002\u0012\u0015\u0012\u0013\u0018\u00010\u0007¢\u0006\f\b\b\u0012\b\b\t\u0012\u0004\b\b(\n\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u00010\u000b\u0012\u0006\u0012\u0004\u0018\u00010\f0\u0006¢\u0006\u0002\b\rø\u0001\u0000¢\u0006\u0002\u0010\u0012\u001aS\u0010\u0013\u001a\b\u0012\u0004\u0012\u0002H\u00040\u0011\"\u0004\b\u0000\u0010\u0004*\b\u0012\u0004\u0012\u0002H\u00040\u00112-\u0010\u0005\u001a)\b\u0001\u0012\n\u0012\b\u0012\u0004\u0012\u0002H\u00040\u0002\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u00010\u000b\u0012\u0006\u0012\u0004\u0018\u00010\f0\u0014¢\u0006\u0002\b\rø\u0001\u0000¢\u0006\u0002\u0010\u0015\u001aS\u0010\u0016\u001a\b\u0012\u0004\u0012\u0002H\u00040\u0011\"\u0004\b\u0000\u0010\u0004*\b\u0012\u0004\u0012\u0002H\u00040\u00112-\u0010\u0005\u001a)\b\u0001\u0012\n\u0012\b\u0012\u0004\u0012\u0002H\u00040\u0002\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u00010\u000b\u0012\u0006\u0012\u0004\u0018\u00010\f0\u0014¢\u0006\u0002\b\rø\u0001\u0000¢\u0006\u0002\u0010\u0015\u001as\u0010\u0017\u001a\b\u0012\u0004\u0012\u0002H\u00180\u0011\"\u0004\b\u0000\u0010\u0004\"\u0004\b\u0001\u0010\u0018*\b\u0012\u0004\u0012\u0002H\u00040\u00112D\b\u0005\u0010\u0017\u001a>\b\u0001\u0012\n\u0012\b\u0012\u0004\u0012\u0002H\u00180\u0002\u0012\u0013\u0012\u0011H\u0004¢\u0006\f\b\b\u0012\b\b\t\u0012\u0004\b\b(\u0019\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u00010\u000b\u0012\u0006\u0012\u0004\u0018\u00010\f0\u0006¢\u0006\u0002\b\rH\u0086\bø\u0001\u0000¢\u0006\u0002\u0010\u0012\u001as\u0010\u001a\u001a\b\u0012\u0004\u0012\u0002H\u00180\u0011\"\u0004\b\u0000\u0010\u0004\"\u0004\b\u0001\u0010\u0018*\b\u0012\u0004\u0012\u0002H\u00040\u00112D\b\u0005\u0010\u0017\u001a>\b\u0001\u0012\n\u0012\b\u0012\u0004\u0012\u0002H\u00180\u0002\u0012\u0013\u0012\u0011H\u0004¢\u0006\f\b\b\u0012\b\b\t\u0012\u0004\b\b(\u0019\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u00010\u000b\u0012\u0006\u0012\u0004\u0018\u00010\f0\u0006¢\u0006\u0002\b\rH\u0081\bø\u0001\u0000¢\u0006\u0002\u0010\u0012\u0082\u0002\u0004\n\u0002\b\u0019¨\u0006\u001b"}, d2 = {"ensureActive", "", "Lkotlinx/coroutines/flow/FlowCollector;", "invokeSafely", "T", "action", "Lkotlin/Function3;", "", "Lkotlin/ParameterName;", "name", "cause", "Lkotlin/coroutines/Continuation;", "", "Lkotlin/ExtensionFunctionType;", "invokeSafely$FlowKt__EmittersKt", "(Lkotlinx/coroutines/flow/FlowCollector;Lkotlin/jvm/functions/Function3;Ljava/lang/Throwable;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "onCompletion", "Lkotlinx/coroutines/flow/Flow;", "(Lkotlinx/coroutines/flow/Flow;Lkotlin/jvm/functions/Function3;)Lkotlinx/coroutines/flow/Flow;", "onEmpty", "Lkotlin/Function2;", "(Lkotlinx/coroutines/flow/Flow;Lkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/flow/Flow;", "onStart", "transform", "R", "value", "unsafeTransform", "kotlinx-coroutines-core"}, k = 5, mv = {1, 6, 0}, xi = 48, xs = "kotlinx/coroutines/flow/FlowKt") final /* synthetic */ class FlowKt__EmittersKt { /* JADX INFO: Add missing generic type declarations: [R] */ /* JADX INFO: renamed from: kotlinx.coroutines.flow.FlowKt__EmittersKt$transform$1, reason: invalid class name */ /* JADX INFO: compiled from: Emitters.kt */ @Metadata(d1 = {"\u0000\u000e\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\u0010\u0000\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u0002\"\u0004\b\u0001\u0010\u0003*\b\u0012\u0004\u0012\u0002H\u00030\u0004H\u008a@"}, d2 = {"", "", "T", "R", "Lkotlinx/coroutines/flow/FlowCollector;"}, k = 3, mv = {1, 6, 0}, xi = Opcodes.ARETURN) @DebugMetadata(c = "kotlinx.coroutines.flow.FlowKt__EmittersKt$transform$1", f = "Emitters.kt", i = {}, l = {40}, m = "invokeSuspend", n = {}, s = {}) public static final class AnonymousClass1 extends SuspendLambda implements Function2, Continuation, Object> { final /* synthetic */ Flow $this_transform; final /* synthetic */ Function3, T, Continuation, Object> $transform; private /* synthetic */ Object L$0; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ /* JADX WARN: Multi-variable type inference failed */ public AnonymousClass1(Flow flow, Function3, ? super T, ? super Continuation, ? extends Object> function3, Continuation continuation) { super(2, continuation); this.$this_transform = flow; this.$transform = function3; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { AnonymousClass1 anonymousClass1 = new AnonymousClass1(this.$this_transform, this.$transform, continuation); anonymousClass1.L$0 = obj; return anonymousClass1; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(FlowCollector flowCollector, Continuation continuation) { return ((AnonymousClass1) create(flowCollector, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX INFO: renamed from: kotlinx.coroutines.flow.FlowKt__EmittersKt$transform$1$1, reason: invalid class name and collision with other inner class name */ /* JADX INFO: compiled from: Emitters.kt */ @Metadata(d1 = {"\u0000\n\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0005\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"}, d2 = {"", "", "T", "R", "value", "emit", "(Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;"}, k = 3, mv = {1, 6, 0}, xi = Opcodes.ARETURN) public static final class C00101 implements FlowCollector { final /* synthetic */ FlowCollector $$this$flow; final /* synthetic */ Function3, T, Continuation, Object> $transform; /* JADX WARN: Multi-variable type inference failed */ public C00101(Function3, ? super T, ? super Continuation, ? extends Object> function3, FlowCollector flowCollector) { this.$transform = function3; this.$$this$flow = flowCollector; } /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Type inference incomplete: some casts might be missing */ @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 r5, kotlin.coroutines.Continuation r6) throws java.lang.Throwable { /* r4 = this; boolean r0 = r6 instanceof kotlinx.coroutines.flow.FlowKt__EmittersKt$transform$1$1$emit$1 if (r0 == 0) goto L14 r0 = r6 kotlinx.coroutines.flow.FlowKt__EmittersKt$transform$1$1$emit$1 r0 = (kotlinx.coroutines.flow.FlowKt__EmittersKt$transform$1$1$emit$1) r0 int r1 = r0.label r2 = -2147483648(0xffffffff80000000, float:-0.0) r1 = r1 & r2 if (r1 == 0) goto L14 int r6 = r0.label int r6 = r6 - r2 r0.label = r6 goto L19 L14: kotlinx.coroutines.flow.FlowKt__EmittersKt$transform$1$1$emit$1 r0 = new kotlinx.coroutines.flow.FlowKt__EmittersKt$transform$1$1$emit$1 r0.(r4, r6) L19: java.lang.Object r6 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 1 if (r2 == 0) goto L32 if (r2 != r3) goto L2a kotlin.ResultKt.throwOnFailure(r6) goto L42 L2a: java.lang.IllegalStateException r4 = new java.lang.IllegalStateException java.lang.String r5 = "call to 'resume' before 'invoke' with coroutine" r4.(r5) throw r4 L32: kotlin.ResultKt.throwOnFailure(r6) kotlin.jvm.functions.Function3, T, kotlin.coroutines.Continuation, java.lang.Object> r6 = r4.$transform kotlinx.coroutines.flow.FlowCollector r4 = r4.$$this$flow r0.label = r3 java.lang.Object r4 = r6.invoke(r4, r5, r0) if (r4 != r1) goto L42 return r1 L42: kotlin.Unit r4 = kotlin.Unit.INSTANCE return r4 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.flow.FlowKt__EmittersKt.AnonymousClass1.C00101.emit(java.lang.Object, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Type inference incomplete: some casts might be missing */ public final Object emit$$forInline(T t, Continuation continuation) { InlineMarker.mark(4); new FlowKt__EmittersKt$transform$1$1$emit$1(this, continuation); InlineMarker.mark(5); this.$transform.invoke((FlowCollector) this.$$this$flow, t, continuation); return Unit.INSTANCE; } } /* JADX WARN: Type inference incomplete: some casts might be missing */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) throws Throwable { Object coroutine_suspended = IntrinsicsKt.getCOROUTINE_SUSPENDED(); int i = this.label; if (i == 0) { ResultKt.throwOnFailure(obj); FlowCollector flowCollector = (FlowCollector) this.L$0; Flow flow = this.$this_transform; C00101 c00101 = new C00101(this.$transform, flowCollector); this.label = 1; if (flow.collect(c00101, this) == coroutine_suspended) { return coroutine_suspended; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } ResultKt.throwOnFailure(obj); } return Unit.INSTANCE; } /* JADX WARN: Type inference incomplete: some casts might be missing */ public final Object invokeSuspend$$forInline(Object obj) { FlowCollector flowCollector = (FlowCollector) this.L$0; Flow flow = this.$this_transform; C00101 c00101 = new C00101(this.$transform, flowCollector); InlineMarker.mark(0); flow.collect(c00101, this); InlineMarker.mark(1); return Unit.INSTANCE; } } public static final Flow transform(Flow flow, Function3, ? super T, ? super Continuation, ? extends Object> function3) { return FlowKt.flow(new AnonymousClass1(flow, function3, null)); } public static final void ensureActive(FlowCollector flowCollector) { if (flowCollector instanceof ThrowingCollector) { throw ((ThrowingCollector) flowCollector).e; } } /* JADX INFO: Access modifiers changed from: private */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final java.lang.Object invokeSafely$FlowKt__EmittersKt(kotlinx.coroutines.flow.FlowCollector r4, kotlin.jvm.functions.Function3, ? super java.lang.Throwable, ? super kotlin.coroutines.Continuation, ? extends java.lang.Object> r5, java.lang.Throwable r6, kotlin.coroutines.Continuation r7) throws java.lang.Throwable { /* boolean r0 = r7 instanceof kotlinx.coroutines.flow.FlowKt__EmittersKt$invokeSafely$1 if (r0 == 0) goto L14 r0 = r7 kotlinx.coroutines.flow.FlowKt__EmittersKt$invokeSafely$1 r0 = (kotlinx.coroutines.flow.FlowKt__EmittersKt$invokeSafely$1) r0 int r1 = r0.label r2 = -2147483648(0xffffffff80000000, float:-0.0) r1 = r1 & r2 if (r1 == 0) goto L14 int r7 = r0.label int r7 = r7 - r2 r0.label = r7 goto L19 L14: kotlinx.coroutines.flow.FlowKt__EmittersKt$invokeSafely$1 r0 = new kotlinx.coroutines.flow.FlowKt__EmittersKt$invokeSafely$1 r0.(r7) L19: java.lang.Object r7 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 1 if (r2 == 0) goto L37 if (r2 != r3) goto L2f java.lang.Object r4 = r0.L$0 r6 = r4 java.lang.Throwable r6 = (java.lang.Throwable) r6 kotlin.ResultKt.throwOnFailure(r7) // Catch: java.lang.Throwable -> L48 goto L45 L2f: java.lang.IllegalStateException r4 = new java.lang.IllegalStateException java.lang.String r5 = "call to 'resume' before 'invoke' with coroutine" r4.(r5) throw r4 L37: kotlin.ResultKt.throwOnFailure(r7) r0.L$0 = r6 // Catch: java.lang.Throwable -> L48 r0.label = r3 // Catch: java.lang.Throwable -> L48 java.lang.Object r4 = r5.invoke(r4, r6, r0) // Catch: java.lang.Throwable -> L48 if (r4 != r1) goto L45 return r1 L45: kotlin.Unit r4 = kotlin.Unit.INSTANCE return r4 L48: r4 = move-exception if (r6 == 0) goto L50 if (r6 == r4) goto L50 kotlin.ExceptionsKt.addSuppressed(r4, r6) L50: throw r4 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.flow.FlowKt__EmittersKt.invokeSafely$FlowKt__EmittersKt(kotlinx.coroutines.flow.FlowCollector, kotlin.jvm.functions.Function3, java.lang.Throwable, kotlin.coroutines.Continuation):java.lang.Object"); } public static final Flow unsafeTransform(Flow flow, Function3, ? super T, ? super Continuation, ? extends Object> function3) { return new FlowKt__EmittersKt$unsafeTransform$$inlined$unsafeFlow$1(flow, function3); } public static final Flow onStart(Flow flow, Function2, ? super Continuation, ? extends Object> function2) { return new FlowKt__EmittersKt$onStart$$inlined$unsafeFlow$1(function2, flow); } public static final Flow onCompletion(Flow flow, Function3, ? super Throwable, ? super Continuation, ? extends Object> function3) { return new FlowKt__EmittersKt$onCompletion$$inlined$unsafeFlow$1(flow, function3); } public static final Flow onEmpty(Flow flow, Function2, ? super Continuation, ? extends Object> function2) { return new FlowKt__EmittersKt$onEmpty$$inlined$unsafeFlow$1(flow, function2); } }