content: package kotlinx.coroutines.flow;
  
  import kotlin.Metadata;
  import kotlin.Unit;
  import kotlin.coroutines.Continuation;
  import kotlin.jvm.functions.Function2;
  import kotlin.jvm.functions.Function3;
  import kotlin.jvm.internal.InlineMarker;
  import kotlin.jvm.internal.Intrinsics;
  import kotlinx.coroutines.flow.internal.AbortFlowException;
  import kotlinx.coroutines.flow.internal.FlowExceptions_commonKt;
  import mt.Log1F380D;
  
  @Metadata(d1 = {"\u0000F\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\u0010\u0000\n\u0002\b\u0003\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u001aV\u0010\u0000\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u0002*\b\u0012\u0004\u0012\u0002H\u00020\u000323\b\u0004\u0010\u0004\u001a-\b\u0001\u0012\u0013\u0012\u0011H\u0002¢\u0006\f\b\u0006\u0012\b\b\u0007\u0012\u0004\b\b(\b\u0012\n\u0012\b\u0012\u0004\u0012\u00020\n0\t\u0012\u0006\u0012\u0004\u0018\u00010\u000b0\u0005HHø\u0001\u0000¢\u0006\u0002\u0010\f\u001a$\u0010\r\u001a\b\u0012\u0004\u0012\u0002H\u00020\u0003\"\u0004\b\u0000\u0010\u0002*\b\u0012\u0004\u0012\u0002H\u00020\u00032\u0006\u0010\u000e\u001a\u00020\u000f\u001aH\u0010\u0010\u001a\b\u0012\u0004\u0012\u0002H\u00020\u0003\"\u0004\b\u0000\u0010\u0002*\b\u0012\u0004\u0012\u0002H\u00020\u00032\"\u0010\u0004\u001a\u001e\b\u0001\u0012\u0004\u0012\u0002H\u0002\u0012\n\u0012\b\u0012\u0004\u0012\u00020\n0\t\u0012\u0006\u0012\u0004\u0018\u00010\u000b0\u0005ø\u0001\u0000¢\u0006\u0002\u0010\u0011\u001a+\u0010\u0012\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u0002*\b\u0012\u0004\u0012\u0002H\u00020\u00132\u0006\u0010\b\u001a\u0002H\u0002H@ø\u0001\u0000¢\u0006\u0004\b\u0014\u0010\u0015\u001a$\u0010\u0016\u001a\b\u0012\u0004\u0012\u0002H\u00020\u0003\"\u0004\b\u0000\u0010\u0002*\b\u0012\u0004\u0012\u0002H\u00020\u00032\u0006\u0010\u000e\u001a\u00020\u000f\u001aH\u0010\u0017\u001a\b\u0012\u0004\u0012\u0002H\u00020\u0003\"\u0004\b\u0000\u0010\u0002*\b\u0012\u0004\u0012\u0002H\u00020\u00032\"\u0010\u0004\u001a\u001e\b\u0001\u0012\u0004\u0012\u0002H\u0002\u0012\n\u0012\b\u0012\u0004\u0012\u00020\n0\t\u0012\u0006\u0012\u0004\u0018\u00010\u000b0\u0005ø\u0001\u0000¢\u0006\u0002\u0010\u0011\u001ap\u0010\u0018\u001a\b\u0012\u0004\u0012\u0002H\u00190\u0003\"\u0004\b\u0000\u0010\u0002\"\u0004\b\u0001\u0010\u0019*\b\u0012\u0004\u0012\u0002H\u00020\u00032D\b\u0001\u0010\u001a\u001a>\b\u0001\u0012\n\u0012\b\u0012\u0004\u0012\u0002H\u00190\u0013\u0012\u0013\u0012\u0011H\u0002¢\u0006\f\b\u0006\u0012\b\b\u0007\u0012\u0004\b\b(\b\u0012\n\u0012\b\u0012\u0004\u0012\u00020\n0\t\u0012\u0006\u0012\u0004\u0018\u00010\u000b0\u001b¢\u0006\u0002\b\u001cø\u0001\u0000¢\u0006\u0002\u0010\u001d\u0002\u0004\n\u0002\b\u0019¨\u0006\u001e"}, d2 = {"collectWhile", "", "T", "Lkotlinx/coroutines/flow/Flow;", "predicate", "Lkotlin/Function2;", "Lkotlin/ParameterName;", "name", "value", "Lkotlin/coroutines/Continuation;", "", "", "(Lkotlinx/coroutines/flow/Flow;Lkotlin/jvm/functions/Function2;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "drop", "count", "", "dropWhile", "(Lkotlinx/coroutines/flow/Flow;Lkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/flow/Flow;", "emitAbort", "Lkotlinx/coroutines/flow/FlowCollector;", "emitAbort$FlowKt__LimitKt", "(Lkotlinx/coroutines/flow/FlowCollector;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "take", "takeWhile", "transformWhile", "R", "transform", "Lkotlin/Function3;", "Lkotlin/ExtensionFunctionType;", "(Lkotlinx/coroutines/flow/Flow;Lkotlin/jvm/functions/Function3;)Lkotlinx/coroutines/flow/Flow;", "kotlinx-coroutines-core"}, k = 5, mv = {1, 6, 0}, xi = 48, xs = "kotlinx/coroutines/flow/FlowKt")
  /* compiled from: 0195 */
  final /* synthetic */ class FlowKt__LimitKt {
      /* JADX WARNING: Can't fix incorrect switch cases order */
      /* JADX WARNING: Removed duplicated region for block: B:10:0x002d  */
      /* JADX WARNING: Removed duplicated region for block: B:14:0x0038  */
      /* JADX WARNING: Removed duplicated region for block: B:8:0x0025  */
      /* Code decompiled incorrectly, please refer to instructions dump. */
      public static final <T> java.lang.Object collectWhile(kotlinx.coroutines.flow.Flow<? extends T> r5, kotlin.jvm.functions.Function2<? super T, ? super kotlin.coroutines.Continuation<? super java.lang.Boolean>, ? extends java.lang.Object> r6, kotlin.coroutines.Continuation<? super kotlin.Unit> r7) {
          /*
              boolean r0 = r7 instanceof kotlinx.coroutines.flow.FlowKt__LimitKt$collectWhile$1
              if (r0 == 0) goto L_0x0014
              r0 = r7
              kotlinx.coroutines.flow.FlowKt__LimitKt$collectWhile$1 r0 = (kotlinx.coroutines.flow.FlowKt__LimitKt$collectWhile$1) r0
              int r1 = r0.label
              r2 = -2147483648(0xffffffff80000000, float:-0.0)
              r1 = r1 & r2
              if (r1 == 0) goto L_0x0014
              int r7 = r0.label
              int r7 = r7 - r2
              r0.label = r7
              goto L_0x0019
          L_0x0014:
              kotlinx.coroutines.flow.FlowKt__LimitKt$collectWhile$1 r0 = new kotlinx.coroutines.flow.FlowKt__LimitKt$collectWhile$1
              r0.<init>(r7)
          L_0x0019:
              r7 = r0
              java.lang.Object r0 = r7.result
              java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED()
              int r2 = r7.label
              switch(r2) {
                  case 0: goto L_0x0038;
                  case 1: goto L_0x002d;
                  default: goto L_0x0025;
              }
          L_0x0025:
              java.lang.IllegalStateException r5 = new java.lang.IllegalStateException
              java.lang.String r6 = "call to 'resume' before 'invoke' with coroutine"
              r5.<init>(r6)
              throw r5
          L_0x002d:
              r5 = 0
              java.lang.Object r6 = r7.L$0
              kotlinx.coroutines.flow.FlowKt__LimitKt$collectWhile$collector$1 r6 = (kotlinx.coroutines.flow.FlowKt__LimitKt$collectWhile$collector$1) r6
              kotlin.ResultKt.throwOnFailure(r0)     // Catch:{ AbortFlowException -> 0x0036 }
              goto L_0x0053
          L_0x0036:
              r1 = move-exception
              goto L_0x0057
          L_0x0038:
              kotlin.ResultKt.throwOnFailure(r0)
              r2 = 0
              kotlinx.coroutines.flow.FlowKt__LimitKt$collectWhile$collector$1 r3 = new kotlinx.coroutines.flow.FlowKt__LimitKt$collectWhile$collector$1
              r3.<init>(r6)
              r6 = r3
              kotlinx.coroutines.flow.FlowCollector r6 = (kotlinx.coroutines.flow.FlowCollector) r6     // Catch:{ AbortFlowException -> 0x0054 }
              r7.L$0 = r3     // Catch:{ AbortFlowException -> 0x0054 }
              r4 = 1
              r7.label = r4     // Catch:{ AbortFlowException -> 0x0054 }
              java.lang.Object r6 = r5.collect(r6, r7)     // Catch:{ AbortFlowException -> 0x0054 }
              if (r6 != r1) goto L_0x0051
              return r1
          L_0x0051:
              r5 = r2
              r6 = r3
          L_0x0053:
              goto L_0x005d
          L_0x0054:
              r1 = move-exception
              r5 = r2
              r6 = r3
          L_0x0057:
              r2 = r6
              kotlinx.coroutines.flow.FlowCollector r2 = (kotlinx.coroutines.flow.FlowCollector) r2
              kotlinx.coroutines.flow.internal.FlowExceptions_commonKt.checkOwnership(r1, r2)
          L_0x005d:
              kotlin.Unit r1 = kotlin.Unit.INSTANCE
              return r1
          */
          throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.flow.FlowKt__LimitKt.collectWhile(kotlinx.coroutines.flow.Flow, kotlin.jvm.functions.Function2, kotlin.coroutines.Continuation):java.lang.Object");
      }
  
      private static final <T> Object collectWhile$$forInline(Flow<? extends T> $this$collectWhile, Function2<? super T, ? super Continuation<? super Boolean>, ? extends Object> predicate, Continuation<? super Unit> $completion) {
          FlowKt__LimitKt$collectWhile$collector$1 flowKt__LimitKt$collectWhile$collector$1 = new FlowKt__LimitKt$collectWhile$collector$1(predicate);
          try {
              InlineMarker.mark(0);
              $this$collectWhile.collect(flowKt__LimitKt$collectWhile$collector$1, $completion);
              InlineMarker.mark(1);
          } catch (AbortFlowException e) {
              FlowExceptions_commonKt.checkOwnership(e, flowKt__LimitKt$collectWhile$collector$1);
          }
          return Unit.INSTANCE;
      }
  
      public static final <T> Flow<T> drop(Flow<? extends T> $this$drop, int count) {
          if (count >= 0) {
              return new FlowKt__LimitKt$drop$$inlined$unsafeFlow$1($this$drop, count);
          }
          String stringPlus = Intrinsics.stringPlus("Drop count should be non-negative, but had ", Integer.valueOf(count));
          Log1F380D.a((Object) stringPlus);
          throw new IllegalArgumentException(stringPlus.toString());
      }
  
      public static final <T> Flow<T> dropWhile(Flow<? extends T> $this$dropWhile, Function2<? super T, ? super Continuation<? super Boolean>, ? extends Object> predicate) {
          return new FlowKt__LimitKt$dropWhile$$inlined$unsafeFlow$1($this$dropWhile, predicate);
      }
  
      /* access modifiers changed from: private */
      /* JADX WARNING: Removed duplicated region for block: B:10:0x002d  */
      /* JADX WARNING: Removed duplicated region for block: B:11:0x0035  */
      /* JADX WARNING: Removed duplicated region for block: B:8:0x0025  */
      /* Code decompiled incorrectly, please refer to instructions dump. */
      public static final <T> java.lang.Object emitAbort$FlowKt__LimitKt(kotlinx.coroutines.flow.FlowCollector<? super T> r3, T r4, kotlin.coroutines.Continuation<? super kotlin.Unit> r5) {
          /*
              boolean r0 = r5 instanceof kotlinx.coroutines.flow.FlowKt__LimitKt$emitAbort$1
              if (r0 == 0) goto L_0x0014
              r0 = r5
              kotlinx.coroutines.flow.FlowKt__LimitKt$emitAbort$1 r0 = (kotlinx.coroutines.flow.FlowKt__LimitKt$emitAbort$1) r0
              int r1 = r0.label
              r2 = -2147483648(0xffffffff80000000, float:-0.0)
              r1 = r1 & r2
              if (r1 == 0) goto L_0x0014
              int r5 = r0.label
              int r5 = r5 - r2
              r0.label = r5
              goto L_0x0019
          L_0x0014:
              kotlinx.coroutines.flow.FlowKt__LimitKt$emitAbort$1 r0 = new kotlinx.coroutines.flow.FlowKt__LimitKt$emitAbort$1
              r0.<init>(r5)
          L_0x0019:
              r5 = r0
              java.lang.Object r0 = r5.result
              java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED()
              int r2 = r5.label
              switch(r2) {
                  case 0: goto L_0x0035;
                  case 1: goto L_0x002d;
                  default: goto L_0x0025;
              }
          L_0x0025:
              java.lang.IllegalStateException r3 = new java.lang.IllegalStateException
              java.lang.String r4 = "call to 'resume' before 'invoke' with coroutine"
              r3.<init>(r4)
              throw r3
          L_0x002d:
              java.lang.Object r3 = r5.L$0
              kotlinx.coroutines.flow.FlowCollector r3 = (kotlinx.coroutines.flow.FlowCollector) r3
              kotlin.ResultKt.throwOnFailure(r0)
              goto L_0x0044
          L_0x0035:
              kotlin.ResultKt.throwOnFailure(r0)
              r5.L$0 = r3
              r2 = 1
              r5.label = r2
              java.lang.Object r4 = r3.emit(r4, r5)
              if (r4 != r1) goto L_0x0044
              return r1
          L_0x0044:
              kotlinx.coroutines.flow.internal.AbortFlowException r4 = new kotlinx.coroutines.flow.internal.AbortFlowException
              r4.<init>(r3)
              throw r4
          */
          throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.flow.FlowKt__LimitKt.emitAbort$FlowKt__LimitKt(kotlinx.coroutines.flow.FlowCollector, java.lang.Object, kotlin.coroutines.Continuation):java.lang.Object");
      }
  
      public static final <T> Flow<T> take(Flow<? extends T> $this$take, int count) {
          if (count > 0) {
              return new FlowKt__LimitKt$take$$inlined$unsafeFlow$1($this$take, count);
          }
          throw new IllegalArgumentException(("Requested element count " + count + " should be positive").toString());
      }
  
      public static final <T> Flow<T> takeWhile(Flow<? extends T> $this$takeWhile, Function2<? super T, ? super Continuation<? super Boolean>, ? extends Object> predicate) {
          return new FlowKt__LimitKt$takeWhile$$inlined$unsafeFlow$1($this$takeWhile, predicate);
      }
  
      public static final <T, R> Flow<R> transformWhile(Flow<? extends T> $this$transformWhile, Function3<? super FlowCollector<? super R>, ? super T, ? super Continuation<? super Boolean>, ? extends Object> transform) {
          return FlowKt.flow(new FlowKt__LimitKt$transformWhile$1($this$transformWhile, transform, (Continuation<? super FlowKt__LimitKt$transformWhile$1>) null));
      }
  }
  