package kotlinx.coroutines.channels; import com.alibaba.fastjson.asm.Opcodes; import com.cvte.vman.instance.InvokeCmd; import com.seewo.vcommons.utils.LanguageUtils; import io.reactivex.annotations.SchedulerSupport; import java.util.Collection; import java.util.LinkedHashSet; import java.util.Map; import java.util.Set; import kotlin.Deprecated; import kotlin.DeprecationLevel; import kotlin.ExceptionsKt; import kotlin.Metadata; import kotlin.ResultKt; import kotlin.Unit; import kotlin.collections.IndexedValue; import kotlin.coroutines.Continuation; import kotlin.coroutines.CoroutineContext; import kotlin.coroutines.intrinsics.IntrinsicsKt; import kotlin.coroutines.jvm.internal.Boxing; import kotlin.coroutines.jvm.internal.ContinuationImpl; import kotlin.coroutines.jvm.internal.DebugMetadata; import kotlin.coroutines.jvm.internal.SuspendLambda; import kotlin.jvm.functions.Function1; import kotlin.jvm.functions.Function2; import kotlin.jvm.functions.Function3; import kotlinx.coroutines.Dispatchers; import kotlinx.coroutines.GlobalScope; import org.eclipse.paho.mqttv5.common.packet.MqttReturnCode; /* JADX INFO: compiled from: Deprecated.kt */ /* JADX INFO: loaded from: classes2.dex */ @Metadata(d1 = {"\u0000 \u0001\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0011\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\u0004\n\u0002\u0010\b\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u000b\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u001f\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0012\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u000b\n\u0002\u0010$\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010%\n\u0002\b\u0002\n\u0002\u0010!\n\u0000\n\u0002\u0010#\n\u0000\n\u0002\u0010\"\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0005\u001aJ\u0010\u0000\u001a#\u0012\u0015\u0012\u0013\u0018\u00010\u0002¢\u0006\f\b\u0003\u0012\b\b\u0004\u0012\u0004\b\b(\u0005\u0012\u0004\u0012\u00020\u00060\u0001j\u0002`\u00072\u001a\u0010\b\u001a\u000e\u0012\n\b\u0001\u0012\u0006\u0012\u0002\b\u00030\n0\t\"\u0006\u0012\u0002\b\u00030\nH\u0001¢\u0006\u0002\u0010\u000b\u001a!\u0010\f\u001a\u00020\r\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\nH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010\u000f\u001a1\u0010\u0010\u001a#\u0012\u0015\u0012\u0013\u0018\u00010\u0002¢\u0006\f\b\u0003\u0012\b\b\u0004\u0012\u0004\b\b(\u0005\u0012\u0004\u0012\u00020\u00060\u0001j\u0002`\u0007*\u0006\u0012\u0002\b\u00030\nH\u0001\u001a!\u0010\u0011\u001a\u00020\u0012\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\nH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010\u000f\u001a\u001e\u0010\u0013\u001a\b\u0012\u0004\u0012\u0002H\u000e0\n\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\nH\u0007\u001aZ\u0010\u0014\u001a\b\u0012\u0004\u0012\u0002H\u000e0\n\"\u0004\b\u0000\u0010\u000e\"\u0004\b\u0001\u0010\u0015*\b\u0012\u0004\u0012\u0002H\u000e0\n2\b\b\u0002\u0010\u0016\u001a\u00020\u00172\"\u0010\u0018\u001a\u001e\b\u0001\u0012\u0004\u0012\u0002H\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u0002H\u00150\u001a\u0012\u0006\u0012\u0004\u0018\u00010\u001b0\u0019H\u0001ø\u0001\u0000¢\u0006\u0002\u0010\u001c\u001a0\u0010\u001d\u001a\b\u0012\u0004\u0012\u0002H\u000e0\n\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\u0006\u0010\u001e\u001a\u00020\u00122\b\b\u0002\u0010\u0016\u001a\u00020\u0017H\u0007\u001aT\u0010\u001f\u001a\b\u0012\u0004\u0012\u0002H\u000e0\n\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\b\b\u0002\u0010\u0016\u001a\u00020\u00172\"\u0010 \u001a\u001e\b\u0001\u0012\u0004\u0012\u0002H\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020\r0\u001a\u0012\u0006\u0012\u0004\u0018\u00010\u001b0\u0019H\u0007ø\u0001\u0000¢\u0006\u0002\u0010\u001c\u001a)\u0010!\u001a\u0002H\u000e\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\u0006\u0010\"\u001a\u00020\u0012H\u0087@ø\u0001\u0000¢\u0006\u0002\u0010#\u001a+\u0010$\u001a\u0004\u0018\u0001H\u000e\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\u0006\u0010\"\u001a\u00020\u0012H\u0087@ø\u0001\u0000¢\u0006\u0002\u0010#\u001aT\u0010%\u001a\b\u0012\u0004\u0012\u0002H\u000e0\n\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\b\b\u0002\u0010\u0016\u001a\u00020\u00172\"\u0010 \u001a\u001e\b\u0001\u0012\u0004\u0012\u0002H\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020\r0\u001a\u0012\u0006\u0012\u0004\u0018\u00010\u001b0\u0019H\u0001ø\u0001\u0000¢\u0006\u0002\u0010\u001c\u001ai\u0010&\u001a\b\u0012\u0004\u0012\u0002H\u000e0\n\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\b\b\u0002\u0010\u0016\u001a\u00020\u001727\u0010 \u001a3\b\u0001\u0012\u0013\u0012\u00110\u0012¢\u0006\f\b\u0003\u0012\b\b\u0004\u0012\u0004\b\b(\"\u0012\u0004\u0012\u0002H\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020\r0\u001a\u0012\u0006\u0012\u0004\u0018\u00010\u001b0'H\u0007ø\u0001\u0000¢\u0006\u0002\u0010(\u001aT\u0010)\u001a\b\u0012\u0004\u0012\u0002H\u000e0\n\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\b\b\u0002\u0010\u0016\u001a\u00020\u00172\"\u0010 \u001a\u001e\b\u0001\u0012\u0004\u0012\u0002H\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020\r0\u001a\u0012\u0006\u0012\u0004\u0018\u00010\u001b0\u0019H\u0007ø\u0001\u0000¢\u0006\u0002\u0010\u001c\u001a$\u0010*\u001a\b\u0012\u0004\u0012\u0002H\u000e0\n\"\b\b\u0000\u0010\u000e*\u00020\u001b*\n\u0012\u0006\u0012\u0004\u0018\u0001H\u000e0\nH\u0001\u001aA\u0010+\u001a\u0002H,\"\b\b\u0000\u0010\u000e*\u00020\u001b\"\u0010\b\u0001\u0010,*\n\u0012\u0006\b\u0000\u0012\u0002H\u000e0-*\n\u0012\u0006\u0012\u0004\u0018\u0001H\u000e0\n2\u0006\u0010.\u001a\u0002H,H\u0087@ø\u0001\u0000¢\u0006\u0002\u0010/\u001a?\u0010+\u001a\u0002H,\"\b\b\u0000\u0010\u000e*\u00020\u001b\"\u000e\b\u0001\u0010,*\b\u0012\u0004\u0012\u0002H\u000e00*\n\u0012\u0006\u0012\u0004\u0018\u0001H\u000e0\n2\u0006\u0010.\u001a\u0002H,H\u0087@ø\u0001\u0000¢\u0006\u0002\u00101\u001a!\u00102\u001a\u0002H\u000e\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\nH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010\u000f\u001a#\u00103\u001a\u0004\u0018\u0001H\u000e\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\nH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010\u000f\u001a`\u00104\u001a\b\u0012\u0004\u0012\u0002H50\n\"\u0004\b\u0000\u0010\u000e\"\u0004\b\u0001\u00105*\b\u0012\u0004\u0012\u0002H\u000e0\n2\b\b\u0002\u0010\u0016\u001a\u00020\u00172(\u00106\u001a$\b\u0001\u0012\u0004\u0012\u0002H\u000e\u0012\u0010\u0012\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u0002H50\n0\u001a\u0012\u0006\u0012\u0004\u0018\u00010\u001b0\u0019H\u0007ø\u0001\u0000¢\u0006\u0002\u0010\u001c\u001a)\u00107\u001a\u00020\u0012\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\u0006\u00108\u001a\u0002H\u000eH\u0087@ø\u0001\u0000¢\u0006\u0002\u00109\u001a!\u0010:\u001a\u0002H\u000e\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\nH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010\u000f\u001a)\u0010;\u001a\u00020\u0012\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\u0006\u00108\u001a\u0002H\u000eH\u0087@ø\u0001\u0000¢\u0006\u0002\u00109\u001a#\u0010<\u001a\u0004\u0018\u0001H\u000e\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\nH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010\u000f\u001aZ\u0010=\u001a\b\u0012\u0004\u0012\u0002H50\n\"\u0004\b\u0000\u0010\u000e\"\u0004\b\u0001\u00105*\b\u0012\u0004\u0012\u0002H\u000e0\n2\b\b\u0002\u0010\u0016\u001a\u00020\u00172\"\u00106\u001a\u001e\b\u0001\u0012\u0004\u0012\u0002H\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u0002H50\u001a\u0012\u0006\u0012\u0004\u0018\u00010\u001b0\u0019H\u0001ø\u0001\u0000¢\u0006\u0002\u0010\u001c\u001ao\u0010>\u001a\b\u0012\u0004\u0012\u0002H50\n\"\u0004\b\u0000\u0010\u000e\"\u0004\b\u0001\u00105*\b\u0012\u0004\u0012\u0002H\u000e0\n2\b\b\u0002\u0010\u0016\u001a\u00020\u001727\u00106\u001a3\b\u0001\u0012\u0013\u0012\u00110\u0012¢\u0006\f\b\u0003\u0012\b\b\u0004\u0012\u0004\b\b(\"\u0012\u0004\u0012\u0002H\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u0002H50\u001a\u0012\u0006\u0012\u0004\u0018\u00010\u001b0'H\u0001ø\u0001\u0000¢\u0006\u0002\u0010(\u001au\u0010?\u001a\b\u0012\u0004\u0012\u0002H50\n\"\u0004\b\u0000\u0010\u000e\"\b\b\u0001\u00105*\u00020\u001b*\b\u0012\u0004\u0012\u0002H\u000e0\n2\b\b\u0002\u0010\u0016\u001a\u00020\u001729\u00106\u001a5\b\u0001\u0012\u0013\u0012\u00110\u0012¢\u0006\f\b\u0003\u0012\b\b\u0004\u0012\u0004\b\b(\"\u0012\u0004\u0012\u0002H\u000e\u0012\f\u0012\n\u0012\u0006\u0012\u0004\u0018\u0001H50\u001a\u0012\u0006\u0012\u0004\u0018\u00010\u001b0'H\u0007ø\u0001\u0000¢\u0006\u0002\u0010(\u001a`\u0010@\u001a\b\u0012\u0004\u0012\u0002H50\n\"\u0004\b\u0000\u0010\u000e\"\b\b\u0001\u00105*\u00020\u001b*\b\u0012\u0004\u0012\u0002H\u000e0\n2\b\b\u0002\u0010\u0016\u001a\u00020\u00172$\u00106\u001a \b\u0001\u0012\u0004\u0012\u0002H\u000e\u0012\f\u0012\n\u0012\u0006\u0012\u0004\u0018\u0001H50\u001a\u0012\u0006\u0012\u0004\u0018\u00010\u001b0\u0019H\u0007ø\u0001\u0000¢\u0006\u0002\u0010\u001c\u001a?\u0010A\u001a\u0004\u0018\u0001H\u000e\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\u001a\u0010B\u001a\u0016\u0012\u0006\b\u0000\u0012\u0002H\u000e0Cj\n\u0012\u0006\b\u0000\u0012\u0002H\u000e`DH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010E\u001a?\u0010F\u001a\u0004\u0018\u0001H\u000e\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\u001a\u0010B\u001a\u0016\u0012\u0006\b\u0000\u0012\u0002H\u000e0Cj\n\u0012\u0006\b\u0000\u0012\u0002H\u000e`DH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010E\u001a!\u0010G\u001a\u00020\r\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\nH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010\u000f\u001a$\u0010H\u001a\b\u0012\u0004\u0012\u0002H\u000e0\n\"\b\b\u0000\u0010\u000e*\u00020\u001b*\n\u0012\u0006\u0012\u0004\u0018\u0001H\u000e0\nH\u0007\u001a!\u0010I\u001a\u0002H\u000e\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\nH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010\u000f\u001a#\u0010J\u001a\u0004\u0018\u0001H\u000e\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\nH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010\u000f\u001a0\u0010K\u001a\b\u0012\u0004\u0012\u0002H\u000e0\n\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\u0006\u0010\u001e\u001a\u00020\u00122\b\b\u0002\u0010\u0016\u001a\u00020\u0017H\u0007\u001aT\u0010L\u001a\b\u0012\u0004\u0012\u0002H\u000e0\n\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\b\b\u0002\u0010\u0016\u001a\u00020\u00172\"\u0010 \u001a\u001e\b\u0001\u0012\u0004\u0012\u0002H\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020\r0\u001a\u0012\u0006\u0012\u0004\u0018\u00010\u001b0\u0019H\u0007ø\u0001\u0000¢\u0006\u0002\u0010\u001c\u001a9\u0010M\u001a\u0002H,\"\u0004\b\u0000\u0010\u000e\"\u000e\b\u0001\u0010,*\b\u0012\u0004\u0012\u0002H\u000e00*\b\u0012\u0004\u0012\u0002H\u000e0\n2\u0006\u0010.\u001a\u0002H,H\u0081@ø\u0001\u0000¢\u0006\u0002\u00101\u001a;\u0010N\u001a\u0002H,\"\u0004\b\u0000\u0010\u000e\"\u0010\b\u0001\u0010,*\n\u0012\u0006\b\u0000\u0012\u0002H\u000e0-*\b\u0012\u0004\u0012\u0002H\u000e0\n2\u0006\u0010.\u001a\u0002H,H\u0081@ø\u0001\u0000¢\u0006\u0002\u0010/\u001a?\u0010O\u001a\u000e\u0012\u0004\u0012\u0002H\u0015\u0012\u0004\u0012\u0002HQ0P\"\u0004\b\u0000\u0010\u0015\"\u0004\b\u0001\u0010Q*\u0014\u0012\u0010\u0012\u000e\u0012\u0004\u0012\u0002H\u0015\u0012\u0004\u0012\u0002HQ0R0\nH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010\u000f\u001aU\u0010O\u001a\u0002HS\"\u0004\b\u0000\u0010\u0015\"\u0004\b\u0001\u0010Q\"\u0018\b\u0002\u0010S*\u0012\u0012\u0006\b\u0000\u0012\u0002H\u0015\u0012\u0006\b\u0000\u0012\u0002HQ0T*\u0014\u0012\u0010\u0012\u000e\u0012\u0004\u0012\u0002H\u0015\u0012\u0004\u0012\u0002HQ0R0\n2\u0006\u0010.\u001a\u0002HSH\u0081@ø\u0001\u0000¢\u0006\u0002\u0010U\u001a'\u0010V\u001a\b\u0012\u0004\u0012\u0002H\u000e0W\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\nH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010\u000f\u001a'\u0010X\u001a\b\u0012\u0004\u0012\u0002H\u000e0Y\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\nH\u0081@ø\u0001\u0000¢\u0006\u0002\u0010\u000f\u001a'\u0010Z\u001a\b\u0012\u0004\u0012\u0002H\u000e0[\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\nH\u0087@ø\u0001\u0000¢\u0006\u0002\u0010\u000f\u001a.\u0010\\\u001a\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u0002H\u000e0]0\n\"\u0004\b\u0000\u0010\u000e*\b\u0012\u0004\u0012\u0002H\u000e0\n2\b\b\u0002\u0010\u0016\u001a\u00020\u0017H\u0007\u001a?\u0010^\u001a\u0014\u0012\u0010\u0012\u000e\u0012\u0004\u0012\u0002H\u000e\u0012\u0004\u0012\u0002H50R0\n\"\u0004\b\u0000\u0010\u000e\"\u0004\b\u0001\u00105*\b\u0012\u0004\u0012\u0002H\u000e0\n2\f\u0010_\u001a\b\u0012\u0004\u0012\u0002H50\nH\u0087\u0004\u001az\u0010^\u001a\b\u0012\u0004\u0012\u0002HQ0\n\"\u0004\b\u0000\u0010\u000e\"\u0004\b\u0001\u00105\"\u0004\b\u0002\u0010Q*\b\u0012\u0004\u0012\u0002H\u000e0\n2\f\u0010_\u001a\b\u0012\u0004\u0012\u0002H50\n2\b\b\u0002\u0010\u0016\u001a\u00020\u001726\u00106\u001a2\u0012\u0013\u0012\u0011H\u000e¢\u0006\f\b\u0003\u0012\b\b\u0004\u0012\u0004\b\b(`\u0012\u0013\u0012\u0011H5¢\u0006\f\b\u0003\u0012\b\b\u0004\u0012\u0004\b\b(a\u0012\u0004\u0012\u0002HQ0\u0019H\u0001\u0082\u0002\u0004\n\u0002\b\u0019¨\u0006b"}, d2 = {"consumesAll", "Lkotlin/Function1;", "", "Lkotlin/ParameterName;", "name", "cause", "", "Lkotlinx/coroutines/CompletionHandler;", "channels", "", "Lkotlinx/coroutines/channels/ReceiveChannel;", "([Lkotlinx/coroutines/channels/ReceiveChannel;)Lkotlin/jvm/functions/Function1;", "any", "", "E", "(Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "consumes", "count", "", "distinct", "distinctBy", "K", "context", "Lkotlin/coroutines/CoroutineContext;", "selector", "Lkotlin/Function2;", "Lkotlin/coroutines/Continuation;", "", "(Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/channels/ReceiveChannel;", "drop", "n", "dropWhile", "predicate", "elementAt", "index", "(Lkotlinx/coroutines/channels/ReceiveChannel;ILkotlin/coroutines/Continuation;)Ljava/lang/Object;", "elementAtOrNull", "filter", "filterIndexed", "Lkotlin/Function3;", "(Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/coroutines/CoroutineContext;Lkotlin/jvm/functions/Function3;)Lkotlinx/coroutines/channels/ReceiveChannel;", "filterNot", "filterNotNull", "filterNotNullTo", "C", "", "destination", "(Lkotlinx/coroutines/channels/ReceiveChannel;Ljava/util/Collection;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "Lkotlinx/coroutines/channels/SendChannel;", "(Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlinx/coroutines/channels/SendChannel;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "first", "firstOrNull", "flatMap", "R", "transform", "indexOf", "element", "(Lkotlinx/coroutines/channels/ReceiveChannel;Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "last", "lastIndexOf", "lastOrNull", "map", "mapIndexed", "mapIndexedNotNull", "mapNotNull", "maxWith", "comparator", "Ljava/util/Comparator;", "Lkotlin/Comparator;", "(Lkotlinx/coroutines/channels/ReceiveChannel;Ljava/util/Comparator;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "minWith", SchedulerSupport.NONE, "requireNoNulls", "single", "singleOrNull", "take", "takeWhile", "toChannel", "toCollection", "toMap", "", "V", "Lkotlin/Pair;", "M", "", "(Lkotlinx/coroutines/channels/ReceiveChannel;Ljava/util/Map;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "toMutableList", "", "toMutableSet", "", "toSet", "", "withIndex", "Lkotlin/collections/IndexedValue;", "zip", "other", "a", "b", "kotlinx-coroutines-core"}, k = 5, mv = {1, 6, 0}, xi = 48, xs = "kotlinx/coroutines/channels/ChannelsKt") final /* synthetic */ class ChannelsKt__DeprecatedKt { /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$any$1, reason: invalid class name */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0}, l = {404}, m = "any", n = {"$this$consume$iv"}, s = {"L$0"}) static final class AnonymousClass1 extends ContinuationImpl { Object L$0; int label; /* synthetic */ Object result; 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 ChannelsKt__DeprecatedKt.any(null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$count$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0}, l = {487}, m = "count", n = {"count", "$this$consume$iv$iv"}, s = {"L$0", "L$1"}) static final class C00841 extends ContinuationImpl { Object L$0; Object L$1; Object L$2; int label; /* synthetic */ Object result; C00841(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 ChannelsKt__DeprecatedKt.count(null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$elementAt$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0, 0}, l = {38}, m = "elementAt", n = {"$this$consume$iv", "index", "count"}, s = {"L$0", "I$0", "I$1"}) static final class C00891 extends ContinuationImpl { int I$0; int I$1; Object L$0; Object L$1; int label; /* synthetic */ Object result; C00891(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 ChannelsKt__DeprecatedKt.elementAt(null, 0, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$elementAtOrNull$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0, 0}, l = {53}, m = "elementAtOrNull", n = {"$this$consume$iv", "index", "count"}, s = {"L$0", "I$0", "I$1"}) static final class C00901 extends ContinuationImpl { int I$0; int I$1; Object L$0; Object L$1; int label; /* synthetic */ Object result; C00901(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 ChannelsKt__DeprecatedKt.elementAtOrNull(null, 0, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filterNotNullTo$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0}, l = {487}, m = "filterNotNullTo", n = {"destination", "$this$consume$iv$iv"}, s = {"L$0", "L$1"}) static final class C00951> extends ContinuationImpl { Object L$0; Object L$1; Object L$2; int label; /* synthetic */ Object result; C00951(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 ChannelsKt__DeprecatedKt.filterNotNullTo((ReceiveChannel) null, (Collection) null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filterNotNullTo$3, reason: invalid class name */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0, 1, 1}, l = {487, 242}, m = "filterNotNullTo", n = {"destination", "$this$consume$iv$iv", "destination", "$this$consume$iv$iv"}, s = {"L$0", "L$1", "L$0", "L$1"}) static final class AnonymousClass3> extends ContinuationImpl { Object L$0; Object L$1; Object L$2; int label; /* synthetic */ Object result; AnonymousClass3(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 ChannelsKt__DeprecatedKt.filterNotNullTo((ReceiveChannel) null, (SendChannel) null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$first$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0}, l = {65}, m = "first", n = {"$this$consume$iv", "iterator"}, s = {"L$0", "L$1"}) static final class C00961 extends ContinuationImpl { Object L$0; Object L$1; int label; /* synthetic */ Object result; C00961(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 ChannelsKt__DeprecatedKt.first(null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$firstOrNull$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0}, l = {InvokeCmd.CMD_SYSTEMCTRL_SET_REMOTE_CTRL_WAKEUP}, m = "firstOrNull", n = {"$this$consume$iv", "iterator"}, s = {"L$0", "L$1"}) static final class C00971 extends ContinuationImpl { Object L$0; Object L$1; int label; /* synthetic */ Object result; C00971(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 ChannelsKt__DeprecatedKt.firstOrNull(null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$indexOf$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0, 0}, l = {487}, m = "indexOf", n = {"element", "index", "$this$consume$iv$iv"}, s = {"L$0", "L$1", "L$2"}) static final class C00991 extends ContinuationImpl { Object L$0; Object L$1; Object L$2; Object L$3; int label; /* synthetic */ Object result; C00991(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 ChannelsKt__DeprecatedKt.indexOf(null, null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$last$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0, 1, 1, 1}, l = {InvokeCmd.CMD_SYSTEMCTRL_CANCEL_CPU_PERFORMANCE, 100}, m = "last", n = {"$this$consume$iv", "iterator", "$this$consume$iv", "iterator", "last"}, s = {"L$0", "L$1", "L$0", "L$1", "L$2"}) static final class C01001 extends ContinuationImpl { Object L$0; Object L$1; Object L$2; int label; /* synthetic */ Object result; C01001(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 ChannelsKt__DeprecatedKt.last(null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$lastIndexOf$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0, 0, 0}, l = {487}, m = "lastIndexOf", n = {"element", "lastIndex", "index", "$this$consume$iv$iv"}, s = {"L$0", "L$1", "L$2", "L$3"}) static final class C01011 extends ContinuationImpl { Object L$0; Object L$1; Object L$2; Object L$3; Object L$4; int label; /* synthetic */ Object result; C01011(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 ChannelsKt__DeprecatedKt.lastIndexOf(null, null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$lastOrNull$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0, 1, 1, 1}, l = {InvokeCmd.CMD_SYSTEMCTRL_SET_SCREENOFF_AUDIO_ENABLE, 126}, m = "lastOrNull", n = {"$this$consume$iv", "iterator", "$this$consume$iv", "iterator", "last"}, s = {"L$0", "L$1", "L$0", "L$1", "L$2"}) static final class C01021 extends ContinuationImpl { Object L$0; Object L$1; Object L$2; int label; /* synthetic */ Object result; C01021(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 ChannelsKt__DeprecatedKt.lastOrNull(null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$maxWith$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0, 0, 1, 1, 1, 1}, l = {420, 422}, m = "maxWith", n = {"comparator", "$this$consume$iv", "iterator", "comparator", "$this$consume$iv", "iterator", "max"}, s = {"L$0", "L$1", "L$2", "L$0", "L$1", "L$2", "L$3"}) static final class C01051 extends ContinuationImpl { Object L$0; Object L$1; Object L$2; Object L$3; int label; /* synthetic */ Object result; C01051(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 ChannelsKt__DeprecatedKt.maxWith(null, null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$minWith$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0, 0, 1, 1, 1, 1}, l = {434, 436}, m = "minWith", n = {"comparator", "$this$consume$iv", "iterator", "comparator", "$this$consume$iv", "iterator", "min"}, s = {"L$0", "L$1", "L$2", "L$0", "L$1", "L$2", "L$3"}) static final class C01061 extends ContinuationImpl { Object L$0; Object L$1; Object L$2; Object L$3; int label; /* synthetic */ Object result; C01061(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 ChannelsKt__DeprecatedKt.minWith(null, null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$none$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0}, l = {447}, m = SchedulerSupport.NONE, n = {"$this$consume$iv"}, s = {"L$0"}) static final class C01071 extends ContinuationImpl { Object L$0; int label; /* synthetic */ Object result; C01071(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 ChannelsKt__DeprecatedKt.none(null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$single$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0, 1, 1}, l = {MqttReturnCode.RETURN_CODE_SERVER_UNAVAILABLE, MqttReturnCode.RETURN_CODE_SERVER_SHUTTING_DOWN}, m = "single", n = {"$this$consume$iv", "iterator", "$this$consume$iv", "single"}, s = {"L$0", "L$1", "L$0", "L$1"}) static final class C01091 extends ContinuationImpl { Object L$0; Object L$1; int label; /* synthetic */ Object result; C01091(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 ChannelsKt__DeprecatedKt.single(null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$singleOrNull$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0, 1, 1}, l = {149, MqttReturnCode.RETURN_CODE_ADMINISTRITIVE_ACTION}, m = "singleOrNull", n = {"$this$consume$iv", "iterator", "$this$consume$iv", "single"}, s = {"L$0", "L$1", "L$0", "L$1"}) static final class C01101 extends ContinuationImpl { Object L$0; Object L$1; int label; /* synthetic */ Object result; C01101(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 ChannelsKt__DeprecatedKt.singleOrNull(null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$toChannel$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0, 1, 1}, l = {487, 278}, m = "toChannel", n = {"destination", "$this$consume$iv$iv", "destination", "$this$consume$iv$iv"}, s = {"L$0", "L$1", "L$0", "L$1"}) static final class C01131> extends ContinuationImpl { Object L$0; Object L$1; Object L$2; int label; /* synthetic */ Object result; C01131(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 ChannelsKt.toChannel(null, null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$toCollection$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0}, l = {487}, m = "toCollection", n = {"destination", "$this$consume$iv$iv"}, s = {"L$0", "L$1"}) static final class C01141> extends ContinuationImpl { Object L$0; Object L$1; Object L$2; int label; /* synthetic */ Object result; C01141(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 ChannelsKt.toCollection(null, null, this); } } /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$toMap$2, reason: invalid class name */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt", f = "Deprecated.kt", i = {0, 0}, l = {487}, m = "toMap", n = {"destination", "$this$consume$iv$iv"}, s = {"L$0", "L$1"}) static final class AnonymousClass2> extends ContinuationImpl { Object L$0; Object L$1; Object L$2; int label; /* synthetic */ Object result; AnonymousClass2(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 ChannelsKt.toMap(null, null, this); } } public static final Function1 consumesAll(final ReceiveChannel... receiveChannelArr) { return new Function1() { // from class: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.consumesAll.1 /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ { super(1); } @Override // kotlin.jvm.functions.Function1 public /* bridge */ /* synthetic */ Unit invoke(Throwable th) throws Throwable { invoke2(th); return Unit.INSTANCE; } /* JADX INFO: renamed from: invoke, reason: avoid collision after fix types in other method */ public final void invoke2(Throwable th) throws Throwable { Throwable th2 = null; for (ReceiveChannel receiveChannel : receiveChannelArr) { try { ChannelsKt.cancelConsumed(receiveChannel, th); } catch (Throwable th3) { if (th2 == null) { th2 = th3; } else { ExceptionsKt.addSuppressed(th2, th3); } } } if (th2 != null) { throw th2; } } }; } /* JADX WARN: Removed duplicated region for block: B:23:0x0060 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:24:0x0061 */ /* JADX WARN: Removed duplicated region for block: B:27:0x006e A[Catch: all -> 0x003b, TRY_LEAVE, TryCatch #2 {all -> 0x003b, blocks: (B:12:0x0037, B:25:0x0066, B:27:0x006e, B:33:0x007e, B:34:0x0098), top: B:46:0x0037 }] */ /* JADX WARN: Removed duplicated region for block: B:33:0x007e A[Catch: all -> 0x003b, TRY_ENTER, TryCatch #2 {all -> 0x003b, blocks: (B:12:0x0037, B:25:0x0066, B:27:0x006e, B:33:0x007e, B:34:0x0098), top: B:46:0x0037 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:24:0x0061 -> B:25:0x0066). Please report as a decompilation issue!!! */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object elementAt(kotlinx.coroutines.channels.ReceiveChannel r10, int r11, kotlin.coroutines.Continuation r12) throws java.lang.Throwable { /* boolean r0 = r12 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00891 if (r0 == 0) goto L14 r0 = r12 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$elementAt$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00891) r0 int r1 = r0.label r2 = -2147483648(0xffffffff80000000, float:-0.0) r1 = r1 & r2 if (r1 == 0) goto L14 int r12 = r0.label int r12 = r12 - r2 r0.label = r12 goto L19 L14: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$elementAt$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$elementAt$1 r0.(r12) L19: java.lang.Object r12 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 46 r4 = 0 r5 = 1 java.lang.String r6 = "ReceiveChannel doesn't contain element at index " if (r2 == 0) goto L46 if (r2 != r5) goto L3e int r10 = r0.I$1 int r11 = r0.I$0 java.lang.Object r2 = r0.L$1 kotlinx.coroutines.channels.ChannelIterator r2 = (kotlinx.coroutines.channels.ChannelIterator) r2 java.lang.Object r7 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r7 = (kotlinx.coroutines.channels.ReceiveChannel) r7 kotlin.ResultKt.throwOnFailure(r12) // Catch: java.lang.Throwable -> L3b goto L66 L3b: r10 = move-exception goto Lb4 L3e: java.lang.IllegalStateException r10 = new java.lang.IllegalStateException java.lang.String r11 = "call to 'resume' before 'invoke' with coroutine" r10.(r11) throw r10 L46: kotlin.ResultKt.throwOnFailure(r12) if (r11 < 0) goto L9d kotlinx.coroutines.channels.ChannelIterator r12 = r10.iterator() // Catch: java.lang.Throwable -> L99 r2 = 0 L50: r0.L$0 = r10 // Catch: java.lang.Throwable -> L99 r0.L$1 = r12 // Catch: java.lang.Throwable -> L99 r0.I$0 = r11 // Catch: java.lang.Throwable -> L99 r0.I$1 = r2 // Catch: java.lang.Throwable -> L99 r0.label = r5 // Catch: java.lang.Throwable -> L99 java.lang.Object r7 = r12.hasNext(r0) // Catch: java.lang.Throwable -> L99 if (r7 != r1) goto L61 return r1 L61: r9 = r7 r7 = r10 r10 = r2 r2 = r12 r12 = r9 L66: java.lang.Boolean r12 = (java.lang.Boolean) r12 // Catch: java.lang.Throwable -> L3b boolean r12 = r12.booleanValue() // Catch: java.lang.Throwable -> L3b if (r12 == 0) goto L7e java.lang.Object r12 = r2.next() // Catch: java.lang.Throwable -> L3b int r8 = r10 + 1 if (r11 != r10) goto L7a kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r7, r4) return r12 L7a: r12 = r2 r10 = r7 r2 = r8 goto L50 L7e: java.lang.IndexOutOfBoundsException r10 = new java.lang.IndexOutOfBoundsException // Catch: java.lang.Throwable -> L3b java.lang.StringBuilder r12 = new java.lang.StringBuilder // Catch: java.lang.Throwable -> L3b r12.() // Catch: java.lang.Throwable -> L3b java.lang.StringBuilder r12 = r12.append(r6) // Catch: java.lang.Throwable -> L3b java.lang.StringBuilder r11 = r12.append(r11) // Catch: java.lang.Throwable -> L3b java.lang.StringBuilder r11 = r11.append(r3) // Catch: java.lang.Throwable -> L3b java.lang.String r11 = r11.toString() // Catch: java.lang.Throwable -> L3b r10.(r11) // Catch: java.lang.Throwable -> L3b throw r10 // Catch: java.lang.Throwable -> L3b L99: r11 = move-exception r7 = r10 r10 = r11 goto Lb4 L9d: java.lang.IndexOutOfBoundsException r12 = new java.lang.IndexOutOfBoundsException // Catch: java.lang.Throwable -> L99 java.lang.StringBuilder r0 = new java.lang.StringBuilder // Catch: java.lang.Throwable -> L99 r0.(r6) // Catch: java.lang.Throwable -> L99 java.lang.StringBuilder r11 = r0.append(r11) // Catch: java.lang.Throwable -> L99 java.lang.StringBuilder r11 = r11.append(r3) // Catch: java.lang.Throwable -> L99 java.lang.String r11 = r11.toString() // Catch: java.lang.Throwable -> L99 r12.(r11) // Catch: java.lang.Throwable -> L99 throw r12 // Catch: java.lang.Throwable -> L99 Lb4: throw r10 // Catch: java.lang.Throwable -> Lb5 Lb5: r11 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r7, r10) throw r11 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.elementAt(kotlinx.coroutines.channels.ReceiveChannel, int, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:25:0x0066 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:26:0x0067 */ /* JADX WARN: Removed duplicated region for block: B:29:0x0074 A[Catch: all -> 0x0089, TRY_LEAVE, TryCatch #0 {all -> 0x0089, blocks: (B:27:0x006c, B:29:0x0074, B:23:0x0056, B:22:0x0050), top: B:43:0x0050 }] */ /* JADX WARN: Removed duplicated region for block: B:35:0x0085 A[DONT_GENERATE] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:26:0x0067 -> B:27:0x006c). Please report as a decompilation issue!!! */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object elementAtOrNull(kotlinx.coroutines.channels.ReceiveChannel r9, int r10, kotlin.coroutines.Continuation r11) throws java.lang.Throwable { /* boolean r0 = r11 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00901 if (r0 == 0) goto L14 r0 = r11 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$elementAtOrNull$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00901) r0 int r1 = r0.label r2 = -2147483648(0xffffffff80000000, float:-0.0) r1 = r1 & r2 if (r1 == 0) goto L14 int r11 = r0.label int r11 = r11 - r2 r0.label = r11 goto L19 L14: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$elementAtOrNull$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$elementAtOrNull$1 r0.(r11) L19: java.lang.Object r11 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 1 r4 = 0 if (r2 == 0) goto L47 if (r2 != r3) goto L3f int r9 = r0.I$1 int r10 = r0.I$0 java.lang.Object r2 = r0.L$1 kotlinx.coroutines.channels.ChannelIterator r2 = (kotlinx.coroutines.channels.ChannelIterator) r2 java.lang.Object r5 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r5 = (kotlinx.coroutines.channels.ReceiveChannel) r5 kotlin.ResultKt.throwOnFailure(r11) // Catch: java.lang.Throwable -> L3d r6 = r4 r8 = r2 r2 = r9 r9 = r5 r5 = r0 r0 = r8 goto L6c L3d: r9 = move-exception goto L8c L3f: java.lang.IllegalStateException r9 = new java.lang.IllegalStateException java.lang.String r10 = "call to 'resume' before 'invoke' with coroutine" r9.(r10) throw r9 L47: kotlin.ResultKt.throwOnFailure(r11) if (r10 >= 0) goto L50 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r9, r4) return r4 L50: kotlinx.coroutines.channels.ChannelIterator r11 = r9.iterator() // Catch: java.lang.Throwable -> L89 r2 = 0 r5 = r4 L56: r0.L$0 = r9 // Catch: java.lang.Throwable -> L89 r0.L$1 = r11 // Catch: java.lang.Throwable -> L89 r0.I$0 = r10 // Catch: java.lang.Throwable -> L89 r0.I$1 = r2 // Catch: java.lang.Throwable -> L89 r0.label = r3 // Catch: java.lang.Throwable -> L89 java.lang.Object r6 = r11.hasNext(r0) // Catch: java.lang.Throwable -> L89 if (r6 != r1) goto L67 return r1 L67: r8 = r0 r0 = r11 r11 = r6 r6 = r5 r5 = r8 L6c: java.lang.Boolean r11 = (java.lang.Boolean) r11 // Catch: java.lang.Throwable -> L89 boolean r11 = r11.booleanValue() // Catch: java.lang.Throwable -> L89 if (r11 == 0) goto L85 java.lang.Object r11 = r0.next() // Catch: java.lang.Throwable -> L89 int r7 = r2 + 1 if (r10 != r2) goto L80 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r9, r6) return r11 L80: r11 = r0 r0 = r5 r5 = r6 r2 = r7 goto L56 L85: kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r9, r6) return r4 L89: r10 = move-exception r5 = r9 r9 = r10 L8c: throw r9 // Catch: java.lang.Throwable -> L8d L8d: r10 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r5, r9) throw r10 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.elementAtOrNull(kotlinx.coroutines.channels.ReceiveChannel, int, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:25:0x005c A[Catch: all -> 0x0032, TRY_LEAVE, TryCatch #1 {all -> 0x0032, blocks: (B:12:0x002e, B:23:0x0054, B:25:0x005c, B:28:0x0065, B:29:0x006c), top: B:38:0x002e }] */ /* JADX WARN: Removed duplicated region for block: B:28:0x0065 A[Catch: all -> 0x0032, TRY_ENTER, TryCatch #1 {all -> 0x0032, blocks: (B:12:0x002e, B:23:0x0054, B:25:0x005c, B:28:0x0065, B:29:0x006c), top: B:38:0x002e }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object first(kotlinx.coroutines.channels.ReceiveChannel r5, kotlin.coroutines.Continuation r6) throws java.lang.Throwable { /* boolean r0 = r6 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00961 if (r0 == 0) goto L14 r0 = r6 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$first$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00961) 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.channels.ChannelsKt__DeprecatedKt$first$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$first$1 r0.(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 L3c if (r2 != r3) goto L34 java.lang.Object r5 = r0.L$1 kotlinx.coroutines.channels.ChannelIterator r5 = (kotlinx.coroutines.channels.ChannelIterator) r5 java.lang.Object r0 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r0 = (kotlinx.coroutines.channels.ReceiveChannel) r0 kotlin.ResultKt.throwOnFailure(r6) // Catch: java.lang.Throwable -> L32 goto L54 L32: r5 = move-exception goto L70 L34: java.lang.IllegalStateException r5 = new java.lang.IllegalStateException java.lang.String r6 = "call to 'resume' before 'invoke' with coroutine" r5.(r6) throw r5 L3c: kotlin.ResultKt.throwOnFailure(r6) kotlinx.coroutines.channels.ChannelIterator r6 = r5.iterator() // Catch: java.lang.Throwable -> L6d r0.L$0 = r5 // Catch: java.lang.Throwable -> L6d r0.L$1 = r6 // Catch: java.lang.Throwable -> L6d r0.label = r3 // Catch: java.lang.Throwable -> L6d java.lang.Object r0 = r6.hasNext(r0) // Catch: java.lang.Throwable -> L6d if (r0 != r1) goto L50 return r1 L50: r4 = r0 r0 = r5 r5 = r6 r6 = r4 L54: java.lang.Boolean r6 = (java.lang.Boolean) r6 // Catch: java.lang.Throwable -> L32 boolean r6 = r6.booleanValue() // Catch: java.lang.Throwable -> L32 if (r6 == 0) goto L65 java.lang.Object r5 = r5.next() // Catch: java.lang.Throwable -> L32 r6 = 0 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r0, r6) return r5 L65: java.util.NoSuchElementException r5 = new java.util.NoSuchElementException // Catch: java.lang.Throwable -> L32 java.lang.String r6 = "ReceiveChannel is empty." r5.(r6) // Catch: java.lang.Throwable -> L32 throw r5 // Catch: java.lang.Throwable -> L32 L6d: r6 = move-exception r0 = r5 r5 = r6 L70: throw r5 // Catch: java.lang.Throwable -> L71 L71: r6 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r0, r5) throw r6 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.first(kotlinx.coroutines.channels.ReceiveChannel, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object firstOrNull(kotlinx.coroutines.channels.ReceiveChannel r5, kotlin.coroutines.Continuation r6) throws java.lang.Throwable { /* boolean r0 = r6 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00971 if (r0 == 0) goto L14 r0 = r6 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$firstOrNull$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00971) 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.channels.ChannelsKt__DeprecatedKt$firstOrNull$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$firstOrNull$1 r0.(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 L3c if (r2 != r3) goto L34 java.lang.Object r5 = r0.L$1 kotlinx.coroutines.channels.ChannelIterator r5 = (kotlinx.coroutines.channels.ChannelIterator) r5 java.lang.Object r0 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r0 = (kotlinx.coroutines.channels.ReceiveChannel) r0 kotlin.ResultKt.throwOnFailure(r6) // Catch: java.lang.Throwable -> L32 goto L54 L32: r5 = move-exception goto L6c L34: java.lang.IllegalStateException r5 = new java.lang.IllegalStateException java.lang.String r6 = "call to 'resume' before 'invoke' with coroutine" r5.(r6) throw r5 L3c: kotlin.ResultKt.throwOnFailure(r6) kotlinx.coroutines.channels.ChannelIterator r6 = r5.iterator() // Catch: java.lang.Throwable -> L69 r0.L$0 = r5 // Catch: java.lang.Throwable -> L69 r0.L$1 = r6 // Catch: java.lang.Throwable -> L69 r0.label = r3 // Catch: java.lang.Throwable -> L69 java.lang.Object r0 = r6.hasNext(r0) // Catch: java.lang.Throwable -> L69 if (r0 != r1) goto L50 return r1 L50: r4 = r0 r0 = r5 r5 = r6 r6 = r4 L54: java.lang.Boolean r6 = (java.lang.Boolean) r6 // Catch: java.lang.Throwable -> L32 boolean r6 = r6.booleanValue() // Catch: java.lang.Throwable -> L32 r1 = 0 if (r6 != 0) goto L61 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r0, r1) return r1 L61: java.lang.Object r5 = r5.next() // Catch: java.lang.Throwable -> L32 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r0, r1) return r5 L69: r6 = move-exception r0 = r5 r5 = r6 L6c: throw r5 // Catch: java.lang.Throwable -> L6d L6d: r6 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r0, r5) throw r6 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.firstOrNull(kotlinx.coroutines.channels.ReceiveChannel, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:23:0x0064 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:24:0x0065 */ /* JADX WARN: Removed duplicated region for block: B:27:0x0070 A[Catch: all -> 0x0039, TryCatch #1 {all -> 0x0039, blocks: (B:12:0x0035, B:25:0x0068, B:27:0x0070, B:29:0x007a, B:32:0x0084, B:21:0x0054, B:33:0x008b), top: B:44:0x0035 }] */ /* JADX WARN: Removed duplicated region for block: B:33:0x008b A[Catch: all -> 0x0039, TRY_LEAVE, TryCatch #1 {all -> 0x0039, blocks: (B:12:0x0035, B:25:0x0068, B:27:0x0070, B:29:0x007a, B:32:0x0084, B:21:0x0054, B:33:0x008b), top: B:44:0x0035 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:24:0x0065 -> B:25:0x0068). Please report as a decompilation issue!!! */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object indexOf(kotlinx.coroutines.channels.ReceiveChannel r7, java.lang.Object r8, kotlin.coroutines.Continuation r9) throws java.lang.Throwable { /* boolean r0 = r9 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00991 if (r0 == 0) goto L14 r0 = r9 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$indexOf$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00991) 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.channels.ChannelsKt__DeprecatedKt$indexOf$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$indexOf$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 = 0 r4 = 1 if (r2 == 0) goto L43 if (r2 != r4) goto L3b java.lang.Object r7 = r0.L$3 kotlinx.coroutines.channels.ChannelIterator r7 = (kotlinx.coroutines.channels.ChannelIterator) r7 java.lang.Object r8 = r0.L$2 kotlinx.coroutines.channels.ReceiveChannel r8 = (kotlinx.coroutines.channels.ReceiveChannel) r8 java.lang.Object r2 = r0.L$1 kotlin.jvm.internal.Ref$IntRef r2 = (kotlin.jvm.internal.Ref.IntRef) r2 java.lang.Object r5 = r0.L$0 kotlin.ResultKt.throwOnFailure(r9) // Catch: java.lang.Throwable -> L39 goto L68 L39: r7 = move-exception goto L9a L3b: java.lang.IllegalStateException r7 = new java.lang.IllegalStateException java.lang.String r8 = "call to 'resume' before 'invoke' with coroutine" r7.(r8) throw r7 L43: kotlin.ResultKt.throwOnFailure(r9) kotlin.jvm.internal.Ref$IntRef r9 = new kotlin.jvm.internal.Ref$IntRef r9.() kotlinx.coroutines.channels.ChannelIterator r2 = r7.iterator() // Catch: java.lang.Throwable -> L96 r6 = r8 r8 = r7 r7 = r2 r2 = r9 r9 = r6 L54: r0.L$0 = r9 // Catch: java.lang.Throwable -> L39 r0.L$1 = r2 // Catch: java.lang.Throwable -> L39 r0.L$2 = r8 // Catch: java.lang.Throwable -> L39 r0.L$3 = r7 // Catch: java.lang.Throwable -> L39 r0.label = r4 // Catch: java.lang.Throwable -> L39 java.lang.Object r5 = r7.hasNext(r0) // Catch: java.lang.Throwable -> L39 if (r5 != r1) goto L65 return r1 L65: r6 = r5 r5 = r9 r9 = r6 L68: java.lang.Boolean r9 = (java.lang.Boolean) r9 // Catch: java.lang.Throwable -> L39 boolean r9 = r9.booleanValue() // Catch: java.lang.Throwable -> L39 if (r9 == 0) goto L8b java.lang.Object r9 = r7.next() // Catch: java.lang.Throwable -> L39 boolean r9 = kotlin.jvm.internal.Intrinsics.areEqual(r5, r9) // Catch: java.lang.Throwable -> L39 if (r9 == 0) goto L84 int r7 = r2.element // Catch: java.lang.Throwable -> L39 java.lang.Integer r7 = kotlin.coroutines.jvm.internal.Boxing.boxInt(r7) // Catch: java.lang.Throwable -> L39 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r8, r3) return r7 L84: int r9 = r2.element // Catch: java.lang.Throwable -> L39 int r9 = r9 + r4 r2.element = r9 // Catch: java.lang.Throwable -> L39 r9 = r5 goto L54 L8b: kotlin.Unit r7 = kotlin.Unit.INSTANCE // Catch: java.lang.Throwable -> L39 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r8, r3) r7 = -1 java.lang.Integer r7 = kotlin.coroutines.jvm.internal.Boxing.boxInt(r7) return r7 L96: r8 = move-exception r6 = r8 r8 = r7 r7 = r6 L9a: throw r7 // Catch: java.lang.Throwable -> L9b L9b: r9 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r8, r7) throw r9 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.indexOf(kotlinx.coroutines.channels.ReceiveChannel, java.lang.Object, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:35:0x0087 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:36:0x0088 */ /* JADX WARN: Removed duplicated region for block: B:39:0x0094 A[Catch: all -> 0x0038, TRY_LEAVE, TryCatch #2 {all -> 0x0038, blocks: (B:13:0x0034, B:37:0x008c, B:39:0x0094), top: B:54:0x0034 }] */ /* JADX WARN: Removed duplicated region for block: B:41:0x009a */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:36:0x0088 -> B:37:0x008c). Please report as a decompilation issue!!! */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object last(kotlinx.coroutines.channels.ReceiveChannel r7, kotlin.coroutines.Continuation r8) throws java.lang.Throwable { /* boolean r0 = r8 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01001 if (r0 == 0) goto L14 r0 = r8 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$last$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01001) 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.channels.ChannelsKt__DeprecatedKt$last$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$last$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 r5 = 0 if (r2 == 0) goto L52 if (r2 == r4) goto L44 if (r2 != r3) goto L3c java.lang.Object r7 = r0.L$2 java.lang.Object r2 = r0.L$1 kotlinx.coroutines.channels.ChannelIterator r2 = (kotlinx.coroutines.channels.ChannelIterator) r2 java.lang.Object r4 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r4 = (kotlinx.coroutines.channels.ReceiveChannel) r4 kotlin.ResultKt.throwOnFailure(r8) // Catch: java.lang.Throwable -> L38 goto L8c L38: r7 = move-exception r2 = r4 goto La9 L3c: java.lang.IllegalStateException r7 = new java.lang.IllegalStateException java.lang.String r8 = "call to 'resume' before 'invoke' with coroutine" r7.(r8) throw r7 L44: java.lang.Object r7 = r0.L$1 kotlinx.coroutines.channels.ChannelIterator r7 = (kotlinx.coroutines.channels.ChannelIterator) r7 java.lang.Object r2 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r2 = (kotlinx.coroutines.channels.ReceiveChannel) r2 kotlin.ResultKt.throwOnFailure(r8) // Catch: java.lang.Throwable -> L50 goto L6a L50: r7 = move-exception goto La9 L52: kotlin.ResultKt.throwOnFailure(r8) kotlinx.coroutines.channels.ChannelIterator r8 = r7.iterator() // Catch: java.lang.Throwable -> La6 r0.L$0 = r7 // Catch: java.lang.Throwable -> La6 r0.L$1 = r8 // Catch: java.lang.Throwable -> La6 r0.label = r4 // Catch: java.lang.Throwable -> La6 java.lang.Object r2 = r8.hasNext(r0) // Catch: java.lang.Throwable -> La6 if (r2 != r1) goto L66 return r1 L66: r6 = r2 r2 = r7 r7 = r8 r8 = r6 L6a: java.lang.Boolean r8 = (java.lang.Boolean) r8 // Catch: java.lang.Throwable -> L50 boolean r8 = r8.booleanValue() // Catch: java.lang.Throwable -> L50 if (r8 == 0) goto L9e java.lang.Object r8 = r7.next() // Catch: java.lang.Throwable -> L50 r6 = r2 r2 = r7 r7 = r6 L79: r0.L$0 = r7 // Catch: java.lang.Throwable -> La6 r0.L$1 = r2 // Catch: java.lang.Throwable -> La6 r0.L$2 = r8 // Catch: java.lang.Throwable -> La6 r0.label = r3 // Catch: java.lang.Throwable -> La6 java.lang.Object r4 = r2.hasNext(r0) // Catch: java.lang.Throwable -> La6 if (r4 != r1) goto L88 return r1 L88: r6 = r4 r4 = r7 r7 = r8 r8 = r6 L8c: java.lang.Boolean r8 = (java.lang.Boolean) r8 // Catch: java.lang.Throwable -> L38 boolean r8 = r8.booleanValue() // Catch: java.lang.Throwable -> L38 if (r8 == 0) goto L9a java.lang.Object r8 = r2.next() // Catch: java.lang.Throwable -> L38 r7 = r4 goto L79 L9a: kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r4, r5) return r7 L9e: java.util.NoSuchElementException r7 = new java.util.NoSuchElementException // Catch: java.lang.Throwable -> L50 java.lang.String r8 = "ReceiveChannel is empty." r7.(r8) // Catch: java.lang.Throwable -> L50 throw r7 // Catch: java.lang.Throwable -> L50 La6: r8 = move-exception r2 = r7 r7 = r8 La9: throw r7 // Catch: java.lang.Throwable -> Laa Laa: r8 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r2, r7) throw r8 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.last(kotlinx.coroutines.channels.ReceiveChannel, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:23:0x0073 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:24:0x0074 */ /* JADX WARN: Removed duplicated region for block: B:27:0x007f A[Catch: all -> 0x003d, TryCatch #2 {all -> 0x003d, blocks: (B:12:0x0039, B:25:0x0077, B:27:0x007f, B:29:0x0089, B:30:0x008d, B:21:0x0061, B:31:0x0094), top: B:44:0x0039 }] */ /* JADX WARN: Removed duplicated region for block: B:31:0x0094 A[Catch: all -> 0x003d, TRY_LEAVE, TryCatch #2 {all -> 0x003d, blocks: (B:12:0x0039, B:25:0x0077, B:27:0x007f, B:29:0x0089, B:30:0x008d, B:21:0x0061, B:31:0x0094), top: B:44:0x0039 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:24:0x0074 -> B:25:0x0077). Please report as a decompilation issue!!! */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object lastIndexOf(kotlinx.coroutines.channels.ReceiveChannel r8, java.lang.Object r9, kotlin.coroutines.Continuation r10) throws java.lang.Throwable { /* boolean r0 = r10 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01011 if (r0 == 0) goto L14 r0 = r10 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$lastIndexOf$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01011) r0 int r1 = r0.label r2 = -2147483648(0xffffffff80000000, float:-0.0) r1 = r1 & r2 if (r1 == 0) goto L14 int r10 = r0.label int r10 = r10 - r2 r0.label = r10 goto L19 L14: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$lastIndexOf$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$lastIndexOf$1 r0.(r10) L19: java.lang.Object r10 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 0 r4 = 1 if (r2 == 0) goto L48 if (r2 != r4) goto L40 java.lang.Object r8 = r0.L$4 kotlinx.coroutines.channels.ChannelIterator r8 = (kotlinx.coroutines.channels.ChannelIterator) r8 java.lang.Object r9 = r0.L$3 kotlinx.coroutines.channels.ReceiveChannel r9 = (kotlinx.coroutines.channels.ReceiveChannel) r9 java.lang.Object r2 = r0.L$2 kotlin.jvm.internal.Ref$IntRef r2 = (kotlin.jvm.internal.Ref.IntRef) r2 java.lang.Object r5 = r0.L$1 kotlin.jvm.internal.Ref$IntRef r5 = (kotlin.jvm.internal.Ref.IntRef) r5 java.lang.Object r6 = r0.L$0 kotlin.ResultKt.throwOnFailure(r10) // Catch: java.lang.Throwable -> L3d goto L77 L3d: r8 = move-exception goto La4 L40: java.lang.IllegalStateException r8 = new java.lang.IllegalStateException java.lang.String r9 = "call to 'resume' before 'invoke' with coroutine" r8.(r9) throw r8 L48: kotlin.ResultKt.throwOnFailure(r10) kotlin.jvm.internal.Ref$IntRef r10 = new kotlin.jvm.internal.Ref$IntRef r10.() r2 = -1 r10.element = r2 kotlin.jvm.internal.Ref$IntRef r2 = new kotlin.jvm.internal.Ref$IntRef r2.() kotlinx.coroutines.channels.ChannelIterator r5 = r8.iterator() // Catch: java.lang.Throwable -> La0 r7 = r9 r9 = r8 r8 = r5 r5 = r10 r10 = r7 L61: r0.L$0 = r10 // Catch: java.lang.Throwable -> L3d r0.L$1 = r5 // Catch: java.lang.Throwable -> L3d r0.L$2 = r2 // Catch: java.lang.Throwable -> L3d r0.L$3 = r9 // Catch: java.lang.Throwable -> L3d r0.L$4 = r8 // Catch: java.lang.Throwable -> L3d r0.label = r4 // Catch: java.lang.Throwable -> L3d java.lang.Object r6 = r8.hasNext(r0) // Catch: java.lang.Throwable -> L3d if (r6 != r1) goto L74 return r1 L74: r7 = r6 r6 = r10 r10 = r7 L77: java.lang.Boolean r10 = (java.lang.Boolean) r10 // Catch: java.lang.Throwable -> L3d boolean r10 = r10.booleanValue() // Catch: java.lang.Throwable -> L3d if (r10 == 0) goto L94 java.lang.Object r10 = r8.next() // Catch: java.lang.Throwable -> L3d boolean r10 = kotlin.jvm.internal.Intrinsics.areEqual(r6, r10) // Catch: java.lang.Throwable -> L3d if (r10 == 0) goto L8d int r10 = r2.element // Catch: java.lang.Throwable -> L3d r5.element = r10 // Catch: java.lang.Throwable -> L3d L8d: int r10 = r2.element // Catch: java.lang.Throwable -> L3d int r10 = r10 + r4 r2.element = r10 // Catch: java.lang.Throwable -> L3d r10 = r6 goto L61 L94: kotlin.Unit r8 = kotlin.Unit.INSTANCE // Catch: java.lang.Throwable -> L3d kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r9, r3) int r8 = r5.element java.lang.Integer r8 = kotlin.coroutines.jvm.internal.Boxing.boxInt(r8) return r8 La0: r9 = move-exception r7 = r9 r9 = r8 r8 = r7 La4: throw r8 // Catch: java.lang.Throwable -> La5 La5: r10 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r9, r8) throw r10 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.lastIndexOf(kotlinx.coroutines.channels.ReceiveChannel, java.lang.Object, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:37:0x008b A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:38:0x008c */ /* JADX WARN: Removed duplicated region for block: B:41:0x0098 A[Catch: all -> 0x0038, TRY_LEAVE, TryCatch #3 {all -> 0x0038, blocks: (B:13:0x0034, B:39:0x0090, B:41:0x0098), top: B:57:0x0034 }] */ /* JADX WARN: Removed duplicated region for block: B:43:0x009e */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:38:0x008c -> B:39:0x0090). Please report as a decompilation issue!!! */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object lastOrNull(kotlinx.coroutines.channels.ReceiveChannel r7, kotlin.coroutines.Continuation r8) throws java.lang.Throwable { /* boolean r0 = r8 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01021 if (r0 == 0) goto L14 r0 = r8 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$lastOrNull$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01021) 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.channels.ChannelsKt__DeprecatedKt$lastOrNull$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$lastOrNull$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 r5 = 0 if (r2 == 0) goto L52 if (r2 == r4) goto L44 if (r2 != r3) goto L3c java.lang.Object r7 = r0.L$2 java.lang.Object r2 = r0.L$1 kotlinx.coroutines.channels.ChannelIterator r2 = (kotlinx.coroutines.channels.ChannelIterator) r2 java.lang.Object r4 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r4 = (kotlinx.coroutines.channels.ReceiveChannel) r4 kotlin.ResultKt.throwOnFailure(r8) // Catch: java.lang.Throwable -> L38 goto L90 L38: r7 = move-exception r2 = r4 goto La5 L3c: java.lang.IllegalStateException r7 = new java.lang.IllegalStateException java.lang.String r8 = "call to 'resume' before 'invoke' with coroutine" r7.(r8) throw r7 L44: java.lang.Object r7 = r0.L$1 kotlinx.coroutines.channels.ChannelIterator r7 = (kotlinx.coroutines.channels.ChannelIterator) r7 java.lang.Object r2 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r2 = (kotlinx.coroutines.channels.ReceiveChannel) r2 kotlin.ResultKt.throwOnFailure(r8) // Catch: java.lang.Throwable -> L50 goto L6a L50: r7 = move-exception goto La5 L52: kotlin.ResultKt.throwOnFailure(r8) kotlinx.coroutines.channels.ChannelIterator r8 = r7.iterator() // Catch: java.lang.Throwable -> La2 r0.L$0 = r7 // Catch: java.lang.Throwable -> La2 r0.L$1 = r8 // Catch: java.lang.Throwable -> La2 r0.label = r4 // Catch: java.lang.Throwable -> La2 java.lang.Object r2 = r8.hasNext(r0) // Catch: java.lang.Throwable -> La2 if (r2 != r1) goto L66 return r1 L66: r6 = r2 r2 = r7 r7 = r8 r8 = r6 L6a: java.lang.Boolean r8 = (java.lang.Boolean) r8 // Catch: java.lang.Throwable -> L50 boolean r8 = r8.booleanValue() // Catch: java.lang.Throwable -> L50 if (r8 != 0) goto L76 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r2, r5) return r5 L76: java.lang.Object r8 = r7.next() // Catch: java.lang.Throwable -> L50 r6 = r2 r2 = r7 r7 = r6 L7d: r0.L$0 = r7 // Catch: java.lang.Throwable -> La2 r0.L$1 = r2 // Catch: java.lang.Throwable -> La2 r0.L$2 = r8 // Catch: java.lang.Throwable -> La2 r0.label = r3 // Catch: java.lang.Throwable -> La2 java.lang.Object r4 = r2.hasNext(r0) // Catch: java.lang.Throwable -> La2 if (r4 != r1) goto L8c return r1 L8c: r6 = r4 r4 = r7 r7 = r8 r8 = r6 L90: java.lang.Boolean r8 = (java.lang.Boolean) r8 // Catch: java.lang.Throwable -> L38 boolean r8 = r8.booleanValue() // Catch: java.lang.Throwable -> L38 if (r8 == 0) goto L9e java.lang.Object r8 = r2.next() // Catch: java.lang.Throwable -> L38 r7 = r4 goto L7d L9e: kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r4, r5) return r7 La2: r8 = move-exception r2 = r7 r7 = r8 La5: throw r7 // Catch: java.lang.Throwable -> La6 La6: r8 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r2, r7) throw r8 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.lastOrNull(kotlinx.coroutines.channels.ReceiveChannel, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:31:0x006d A[Catch: all -> 0x004b, TRY_LEAVE, TryCatch #2 {all -> 0x004b, blocks: (B:20:0x0047, B:29:0x0065, B:31:0x006d, B:41:0x0097, B:42:0x009e), top: B:53:0x0047 }] */ /* JADX WARN: Removed duplicated region for block: B:41:0x0097 A[Catch: all -> 0x004b, TRY_ENTER, TryCatch #2 {all -> 0x004b, blocks: (B:20:0x0047, B:29:0x0065, B:31:0x006d, B:41:0x0097, B:42:0x009e), top: B:53:0x0047 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object single(kotlinx.coroutines.channels.ReceiveChannel r6, kotlin.coroutines.Continuation r7) throws java.lang.Throwable { /* boolean r0 = r7 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01091 if (r0 == 0) goto L14 r0 = r7 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$single$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01091) 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.channels.ChannelsKt__DeprecatedKt$single$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$single$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 = 2 r4 = 1 if (r2 == 0) goto L4d if (r2 == r4) goto L3f if (r2 != r3) goto L37 java.lang.Object r6 = r0.L$1 java.lang.Object r0 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r0 = (kotlinx.coroutines.channels.ReceiveChannel) r0 kotlin.ResultKt.throwOnFailure(r7) // Catch: java.lang.Throwable -> L33 goto L82 L33: r6 = move-exception r2 = r0 goto La2 L37: java.lang.IllegalStateException r6 = new java.lang.IllegalStateException java.lang.String r7 = "call to 'resume' before 'invoke' with coroutine" r6.(r7) throw r6 L3f: java.lang.Object r6 = r0.L$1 kotlinx.coroutines.channels.ChannelIterator r6 = (kotlinx.coroutines.channels.ChannelIterator) r6 java.lang.Object r2 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r2 = (kotlinx.coroutines.channels.ReceiveChannel) r2 kotlin.ResultKt.throwOnFailure(r7) // Catch: java.lang.Throwable -> L4b goto L65 L4b: r6 = move-exception goto La2 L4d: kotlin.ResultKt.throwOnFailure(r7) kotlinx.coroutines.channels.ChannelIterator r7 = r6.iterator() // Catch: java.lang.Throwable -> L9f r0.L$0 = r6 // Catch: java.lang.Throwable -> L9f r0.L$1 = r7 // Catch: java.lang.Throwable -> L9f r0.label = r4 // Catch: java.lang.Throwable -> L9f java.lang.Object r2 = r7.hasNext(r0) // Catch: java.lang.Throwable -> L9f if (r2 != r1) goto L61 return r1 L61: r5 = r2 r2 = r6 r6 = r7 r7 = r5 L65: java.lang.Boolean r7 = (java.lang.Boolean) r7 // Catch: java.lang.Throwable -> L4b boolean r7 = r7.booleanValue() // Catch: java.lang.Throwable -> L4b if (r7 == 0) goto L97 java.lang.Object r7 = r6.next() // Catch: java.lang.Throwable -> L4b r0.L$0 = r2 // Catch: java.lang.Throwable -> L4b r0.L$1 = r7 // Catch: java.lang.Throwable -> L4b r0.label = r3 // Catch: java.lang.Throwable -> L4b java.lang.Object r6 = r6.hasNext(r0) // Catch: java.lang.Throwable -> L4b if (r6 != r1) goto L7e return r1 L7e: r0 = r2 r5 = r7 r7 = r6 r6 = r5 L82: java.lang.Boolean r7 = (java.lang.Boolean) r7 // Catch: java.lang.Throwable -> L33 boolean r7 = r7.booleanValue() // Catch: java.lang.Throwable -> L33 if (r7 != 0) goto L8f r7 = 0 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r0, r7) return r6 L8f: java.lang.IllegalArgumentException r6 = new java.lang.IllegalArgumentException // Catch: java.lang.Throwable -> L33 java.lang.String r7 = "ReceiveChannel has more than one element." r6.(r7) // Catch: java.lang.Throwable -> L33 throw r6 // Catch: java.lang.Throwable -> L33 L97: java.util.NoSuchElementException r6 = new java.util.NoSuchElementException // Catch: java.lang.Throwable -> L4b java.lang.String r7 = "ReceiveChannel is empty." r6.(r7) // Catch: java.lang.Throwable -> L4b throw r6 // Catch: java.lang.Throwable -> L4b L9f: r7 = move-exception r2 = r6 r6 = r7 La2: throw r6 // Catch: java.lang.Throwable -> La3 La3: r7 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r2, r6) throw r7 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.single(kotlinx.coroutines.channels.ReceiveChannel, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:39:0x008f */ /* JADX WARN: Removed duplicated region for block: B:41:0x0093 */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object singleOrNull(kotlinx.coroutines.channels.ReceiveChannel r7, kotlin.coroutines.Continuation r8) throws java.lang.Throwable { /* boolean r0 = r8 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01101 if (r0 == 0) goto L14 r0 = r8 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$singleOrNull$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01101) 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.channels.ChannelsKt__DeprecatedKt$singleOrNull$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$singleOrNull$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 r5 = 0 if (r2 == 0) goto L4e if (r2 == r4) goto L40 if (r2 != r3) goto L38 java.lang.Object r7 = r0.L$1 java.lang.Object r0 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r0 = (kotlinx.coroutines.channels.ReceiveChannel) r0 kotlin.ResultKt.throwOnFailure(r8) // Catch: java.lang.Throwable -> L34 goto L87 L34: r7 = move-exception r2 = r0 goto L9a L38: java.lang.IllegalStateException r7 = new java.lang.IllegalStateException java.lang.String r8 = "call to 'resume' before 'invoke' with coroutine" r7.(r8) throw r7 L40: java.lang.Object r7 = r0.L$1 kotlinx.coroutines.channels.ChannelIterator r7 = (kotlinx.coroutines.channels.ChannelIterator) r7 java.lang.Object r2 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r2 = (kotlinx.coroutines.channels.ReceiveChannel) r2 kotlin.ResultKt.throwOnFailure(r8) // Catch: java.lang.Throwable -> L4c goto L66 L4c: r7 = move-exception goto L9a L4e: kotlin.ResultKt.throwOnFailure(r8) kotlinx.coroutines.channels.ChannelIterator r8 = r7.iterator() // Catch: java.lang.Throwable -> L97 r0.L$0 = r7 // Catch: java.lang.Throwable -> L97 r0.L$1 = r8 // Catch: java.lang.Throwable -> L97 r0.label = r4 // Catch: java.lang.Throwable -> L97 java.lang.Object r2 = r8.hasNext(r0) // Catch: java.lang.Throwable -> L97 if (r2 != r1) goto L62 return r1 L62: r6 = r2 r2 = r7 r7 = r8 r8 = r6 L66: java.lang.Boolean r8 = (java.lang.Boolean) r8 // Catch: java.lang.Throwable -> L4c boolean r8 = r8.booleanValue() // Catch: java.lang.Throwable -> L4c if (r8 != 0) goto L72 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r2, r5) return r5 L72: java.lang.Object r8 = r7.next() // Catch: java.lang.Throwable -> L4c r0.L$0 = r2 // Catch: java.lang.Throwable -> L4c r0.L$1 = r8 // Catch: java.lang.Throwable -> L4c r0.label = r3 // Catch: java.lang.Throwable -> L4c java.lang.Object r7 = r7.hasNext(r0) // Catch: java.lang.Throwable -> L4c if (r7 != r1) goto L83 return r1 L83: r0 = r2 r6 = r8 r8 = r7 r7 = r6 L87: java.lang.Boolean r8 = (java.lang.Boolean) r8 // Catch: java.lang.Throwable -> L34 boolean r8 = r8.booleanValue() // Catch: java.lang.Throwable -> L34 if (r8 == 0) goto L93 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r0, r5) return r5 L93: kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r0, r5) return r7 L97: r8 = move-exception r2 = r7 r7 = r8 L9a: throw r7 // Catch: java.lang.Throwable -> L9b L9b: r8 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r2, r7) throw r8 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.singleOrNull(kotlinx.coroutines.channels.ReceiveChannel, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX INFO: Add missing generic type declarations: [E] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$drop$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(d1 = {"\u0000\f\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\u0010\u0000\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u0002*\b\u0012\u0004\u0012\u0002H\u00020\u0003H\u008a@"}, d2 = {"", "", "E", "Lkotlinx/coroutines/channels/ProducerScope;"}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$drop$1", f = "Deprecated.kt", i = {0, 0, 1, 2}, l = {164, Opcodes.RET, 170}, m = "invokeSuspend", n = {"$this$produce", "remaining", "$this$produce", "$this$produce"}, s = {"L$0", "I$0", "L$0", "L$0"}) static final class C00871 extends SuspendLambda implements Function2, Continuation, Object> { final /* synthetic */ int $n; final /* synthetic */ ReceiveChannel $this_drop; int I$0; private /* synthetic */ Object L$0; Object L$1; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ /* JADX WARN: Multi-variable type inference failed */ C00871(int i, ReceiveChannel receiveChannel, Continuation continuation) { super(2, continuation); this.$n = i; this.$this_drop = receiveChannel; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C00871 c00871 = new C00871(this.$n, this.$this_drop, continuation); c00871.L$0 = obj; return c00871; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(ProducerScope producerScope, Continuation continuation) { return ((C00871) create(producerScope, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX WARN: Code restructure failed: missing block: B:26:0x0078, code lost: if (r1 == 0) goto L27; */ /* JADX WARN: Removed duplicated region for block: B:25:0x0073 */ /* JADX WARN: Removed duplicated region for block: B:31:0x0090 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:32:0x0091 */ /* JADX WARN: Removed duplicated region for block: B:35:0x009c */ /* JADX WARN: Removed duplicated region for block: B:38:0x00b0 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:21:0x0068 -> B:23:0x006b). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:36:0x00ad -> B:8:0x001c). Please report as a decompilation issue!!! */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final java.lang.Object invokeSuspend(java.lang.Object r9) throws java.lang.Throwable { /* Method dump skipped, instruction units count: 210 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00871.invokeSuspend(java.lang.Object):java.lang.Object"); } } public static /* synthetic */ ReceiveChannel drop$default(ReceiveChannel receiveChannel, int i, CoroutineContext coroutineContext, int i2, Object obj) { if ((i2 & 2) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return drop(receiveChannel, i, coroutineContext); } @Deprecated(level = DeprecationLevel.HIDDEN, message = "Binary compatibility") public static final /* synthetic */ ReceiveChannel drop(ReceiveChannel receiveChannel, int i, CoroutineContext coroutineContext) { return ProduceKt.produce$default(GlobalScope.INSTANCE, coroutineContext, 0, null, ChannelsKt.consumes(receiveChannel), new C00871(i, receiveChannel, null), 6, null); } public static /* synthetic */ ReceiveChannel dropWhile$default(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2 function2, int i, Object obj) { if ((i & 1) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return dropWhile(receiveChannel, coroutineContext, function2); } /* JADX INFO: Add missing generic type declarations: [E] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$dropWhile$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(d1 = {"\u0000\f\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\u0010\u0000\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u0002*\b\u0012\u0004\u0012\u0002H\u00020\u0003H\u008a@"}, d2 = {"", "", "E", "Lkotlinx/coroutines/channels/ProducerScope;"}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$dropWhile$1", f = "Deprecated.kt", i = {0, 1, 1, 2, 3, 4}, l = {Opcodes.PUTFIELD, Opcodes.INVOKEVIRTUAL, Opcodes.INVOKESPECIAL, Opcodes.NEW, Opcodes.NEWARRAY}, m = "invokeSuspend", n = {"$this$produce", "$this$produce", "e", "$this$produce", "$this$produce", "$this$produce"}, s = {"L$0", "L$0", "L$2", "L$0", "L$0", "L$0"}) static final class C00881 extends SuspendLambda implements Function2, Continuation, Object> { final /* synthetic */ Function2, Object> $predicate; final /* synthetic */ ReceiveChannel $this_dropWhile; private /* synthetic */ Object L$0; Object L$1; Object L$2; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ /* JADX WARN: Multi-variable type inference failed */ C00881(ReceiveChannel receiveChannel, Function2, ? extends Object> function2, Continuation continuation) { super(2, continuation); this.$this_dropWhile = receiveChannel; this.$predicate = function2; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C00881 c00881 = new C00881(this.$this_dropWhile, this.$predicate, continuation); c00881.L$0 = obj; return c00881; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(ProducerScope producerScope, Continuation continuation) { return ((C00881) create(producerScope, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:22:0x0084 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:25:0x008d */ /* JADX WARN: Removed duplicated region for block: B:31:0x00af */ /* JADX WARN: Removed duplicated region for block: B:35:0x00c3 */ /* JADX WARN: Removed duplicated region for block: B:39:0x00da A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:40:0x00db */ /* JADX WARN: Removed duplicated region for block: B:43:0x00e7 */ /* JADX WARN: Removed duplicated region for block: B:46:0x00fb */ /* JADX WARN: Type inference failed for: r10v0 */ /* JADX WARN: Type inference failed for: r10v3 */ /* JADX WARN: Type inference failed for: r1v10, types: [java.lang.Object] */ /* JADX WARN: Type inference failed for: r1v13 */ /* JADX WARN: Type inference failed for: r1v23 */ /* JADX WARN: Type inference failed for: r1v24 */ /* JADX WARN: Type inference failed for: r1v25 */ /* JADX WARN: Type inference failed for: r1v4, types: [java.lang.Object] */ /* JADX WARN: Type inference failed for: r1v7 */ /* JADX WARN: Type inference failed for: r1v8 */ /* JADX WARN: Type inference failed for: r4v1, types: [java.lang.Object, kotlinx.coroutines.channels.ProducerScope] */ /* JADX WARN: Type inference failed for: r4v11 */ /* JADX WARN: Type inference failed for: r4v12 */ /* JADX WARN: Type inference failed for: r4v13 */ /* JADX WARN: Type inference failed for: r4v5 */ /* JADX WARN: Type inference failed for: r4v6 */ /* JADX WARN: Type inference failed for: r8v0 */ /* JADX WARN: Type inference failed for: r8v1 */ /* JADX WARN: Type inference failed for: r8v12 */ /* JADX WARN: Type inference failed for: r8v13 */ /* JADX WARN: Type inference failed for: r8v4, types: [java.lang.Object] */ /* JADX WARN: Type inference failed for: r8v6 */ /* JADX WARN: Type inference failed for: r9v2 */ /* JADX WARN: Type inference failed for: r9v3, types: [java.lang.Object, kotlinx.coroutines.channels.ProducerScope] */ /* JADX WARN: Type inference failed for: r9v6 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:28:0x00a2 -> B:16:0x0054). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:44:0x00f8 -> B:10:0x0023). Please report as a decompilation issue!!! */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final java.lang.Object invokeSuspend(java.lang.Object r12) throws java.lang.Throwable { /* Method dump skipped, instruction units count: 254 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00881.invokeSuspend(java.lang.Object):java.lang.Object"); } } @Deprecated(level = DeprecationLevel.HIDDEN, message = "Binary compatibility") public static final /* synthetic */ ReceiveChannel dropWhile(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2 function2) { return ProduceKt.produce$default(GlobalScope.INSTANCE, coroutineContext, 0, null, ChannelsKt.consumes(receiveChannel), new C00881(receiveChannel, function2, null), 6, null); } public static /* synthetic */ ReceiveChannel filter$default(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2 function2, int i, Object obj) { if ((i & 1) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return ChannelsKt.filter(receiveChannel, coroutineContext, function2); } /* JADX INFO: Add missing generic type declarations: [E] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filter$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(d1 = {"\u0000\f\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\u0010\u0000\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u0002*\b\u0012\u0004\u0012\u0002H\u00020\u0003H\u008a@"}, d2 = {"", "", "E", "Lkotlinx/coroutines/channels/ProducerScope;"}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filter$1", f = "Deprecated.kt", i = {0, 1, 1, 2}, l = {Opcodes.IFNULL, Opcodes.IFNONNULL, Opcodes.IFNONNULL}, m = "invokeSuspend", n = {"$this$produce", "$this$produce", "e", "$this$produce"}, s = {"L$0", "L$0", "L$2", "L$0"}) static final class C00911 extends SuspendLambda implements Function2, Continuation, Object> { final /* synthetic */ Function2, Object> $predicate; final /* synthetic */ ReceiveChannel $this_filter; private /* synthetic */ Object L$0; Object L$1; Object L$2; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ /* JADX WARN: Multi-variable type inference failed */ C00911(ReceiveChannel receiveChannel, Function2, ? extends Object> function2, Continuation continuation) { super(2, continuation); this.$this_filter = receiveChannel; this.$predicate = function2; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C00911 c00911 = new C00911(this.$this_filter, this.$predicate, continuation); c00911.L$0 = obj; return c00911; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(ProducerScope producerScope, Continuation continuation) { return ((C00911) create(producerScope, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX WARN: Code restructure failed: missing block: B:30:0x0051, code lost: r6 = r7; */ /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:18:0x006b */ /* JADX WARN: Removed duplicated region for block: B:24:0x008c */ /* JADX WARN: Removed duplicated region for block: B:27:0x009e */ /* JADX WARN: Removed duplicated region for block: B:28:0x00a0 */ /* JADX WARN: Type inference failed for: r6v0 */ /* JADX WARN: Type inference failed for: r6v13, types: [kotlinx.coroutines.channels.ProducerScope] */ /* JADX WARN: Type inference failed for: r6v14 */ /* JADX WARN: Type inference failed for: r6v15 */ /* JADX WARN: Type inference failed for: r6v2 */ /* JADX WARN: Type inference failed for: r6v3 */ /* JADX WARN: Type inference failed for: r6v4, types: [java.lang.Object] */ /* JADX WARN: Type inference failed for: r6v6, types: [java.lang.Object] */ /* JADX WARN: Type inference failed for: r7v0, types: [java.lang.Object, kotlinx.coroutines.channels.ProducerScope] */ /* JADX WARN: Type inference failed for: r7v3 */ /* JADX WARN: Type inference failed for: r7v6 */ /* JADX WARN: Type inference failed for: r8v0 */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final java.lang.Object invokeSuspend(java.lang.Object r10) throws java.lang.Throwable { /* r9 = this; java.lang.Object r0 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r1 = r9.label r2 = 0 r3 = 3 r4 = 2 r5 = 1 if (r1 == 0) goto L43 if (r1 == r5) goto L37 if (r1 == r4) goto L26 if (r1 != r3) goto L1e java.lang.Object r1 = r9.L$1 kotlinx.coroutines.channels.ChannelIterator r1 = (kotlinx.coroutines.channels.ChannelIterator) r1 java.lang.Object r6 = r9.L$0 kotlinx.coroutines.channels.ProducerScope r6 = (kotlinx.coroutines.channels.ProducerScope) r6 kotlin.ResultKt.throwOnFailure(r10) goto L51 L1e: java.lang.IllegalStateException r9 = new java.lang.IllegalStateException java.lang.String r10 = "call to 'resume' before 'invoke' with coroutine" r9.(r10) throw r9 L26: java.lang.Object r1 = r9.L$2 java.lang.Object r6 = r9.L$1 kotlinx.coroutines.channels.ChannelIterator r6 = (kotlinx.coroutines.channels.ChannelIterator) r6 java.lang.Object r7 = r9.L$0 kotlinx.coroutines.channels.ProducerScope r7 = (kotlinx.coroutines.channels.ProducerScope) r7 kotlin.ResultKt.throwOnFailure(r10) r8 = r6 r6 = r1 r1 = r8 goto L84 L37: java.lang.Object r1 = r9.L$1 kotlinx.coroutines.channels.ChannelIterator r1 = (kotlinx.coroutines.channels.ChannelIterator) r1 java.lang.Object r6 = r9.L$0 kotlinx.coroutines.channels.ProducerScope r6 = (kotlinx.coroutines.channels.ProducerScope) r6 kotlin.ResultKt.throwOnFailure(r10) goto L63 L43: kotlin.ResultKt.throwOnFailure(r10) java.lang.Object r10 = r9.L$0 kotlinx.coroutines.channels.ProducerScope r10 = (kotlinx.coroutines.channels.ProducerScope) r10 kotlinx.coroutines.channels.ReceiveChannel r1 = r9.$this_filter kotlinx.coroutines.channels.ChannelIterator r1 = r1.iterator() r6 = r10 L51: r10 = r9 kotlin.coroutines.Continuation r10 = (kotlin.coroutines.Continuation) r10 r9.L$0 = r6 r9.L$1 = r1 r9.L$2 = r2 r9.label = r5 java.lang.Object r10 = r1.hasNext(r10) if (r10 != r0) goto L63 return r0 L63: java.lang.Boolean r10 = (java.lang.Boolean) r10 boolean r10 = r10.booleanValue() if (r10 == 0) goto La0 java.lang.Object r10 = r1.next() kotlin.jvm.functions.Function2, java.lang.Object> r7 = r9.$predicate r9.L$0 = r6 r9.L$1 = r1 r9.L$2 = r10 r9.label = r4 java.lang.Object r7 = r7.invoke(r10, r9) if (r7 != r0) goto L80 return r0 L80: r8 = r6 r6 = r10 r10 = r7 r7 = r8 L84: java.lang.Boolean r10 = (java.lang.Boolean) r10 boolean r10 = r10.booleanValue() if (r10 == 0) goto L9e r10 = r9 kotlin.coroutines.Continuation r10 = (kotlin.coroutines.Continuation) r10 r9.L$0 = r7 r9.L$1 = r1 r9.L$2 = r2 r9.label = r3 java.lang.Object r10 = r7.send(r6, r10) if (r10 != r0) goto L9e return r0 L9e: r6 = r7 goto L51 La0: kotlin.Unit r9 = kotlin.Unit.INSTANCE return r9 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00911.invokeSuspend(java.lang.Object):java.lang.Object"); } } public static final ReceiveChannel filter(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2, ? extends Object> function2) { return ProduceKt.produce$default(GlobalScope.INSTANCE, coroutineContext, 0, null, ChannelsKt.consumes(receiveChannel), new C00911(receiveChannel, function2, null), 6, null); } public static /* synthetic */ ReceiveChannel filterIndexed$default(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function3 function3, int i, Object obj) { if ((i & 1) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return filterIndexed(receiveChannel, coroutineContext, function3); } /* JADX INFO: Add missing generic type declarations: [E] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filterIndexed$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(d1 = {"\u0000\f\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\u0010\u0000\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u0002*\b\u0012\u0004\u0012\u0002H\u00020\u0003H\u008a@"}, d2 = {"", "", "E", "Lkotlinx/coroutines/channels/ProducerScope;"}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filterIndexed$1", f = "Deprecated.kt", i = {0, 0, 1, 1, 1, 2, 2}, l = {211, 212, 212}, m = "invokeSuspend", n = {"$this$produce", "index", "$this$produce", "e", "index", "$this$produce", "index"}, s = {"L$0", "I$0", "L$0", "L$2", "I$0", "L$0", "I$0"}) static final class C00921 extends SuspendLambda implements Function2, Continuation, Object> { final /* synthetic */ Function3, Object> $predicate; final /* synthetic */ ReceiveChannel $this_filterIndexed; int I$0; private /* synthetic */ Object L$0; Object L$1; Object L$2; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ /* JADX WARN: Multi-variable type inference failed */ C00921(ReceiveChannel receiveChannel, Function3, ? extends Object> function3, Continuation continuation) { super(2, continuation); this.$this_filterIndexed = receiveChannel; this.$predicate = function3; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C00921 c00921 = new C00921(this.$this_filterIndexed, this.$predicate, continuation); c00921.L$0 = obj; return c00921; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(ProducerScope producerScope, Continuation continuation) { return ((C00921) create(producerScope, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX WARN: Code restructure failed: missing block: B:30:0x005b, code lost: r7 = r8; */ /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:18:0x0077 */ /* JADX WARN: Removed duplicated region for block: B:24:0x00a0 */ /* JADX WARN: Removed duplicated region for block: B:27:0x00b4 */ /* JADX WARN: Removed duplicated region for block: B:28:0x00b6 */ /* JADX WARN: Type inference failed for: r7v0 */ /* JADX WARN: Type inference failed for: r7v13, types: [kotlinx.coroutines.channels.ProducerScope] */ /* JADX WARN: Type inference failed for: r7v14 */ /* JADX WARN: Type inference failed for: r7v15 */ /* JADX WARN: Type inference failed for: r7v2 */ /* JADX WARN: Type inference failed for: r7v3 */ /* JADX WARN: Type inference failed for: r7v4, types: [java.lang.Object] */ /* JADX WARN: Type inference failed for: r7v6, types: [java.lang.Object] */ /* JADX WARN: Type inference failed for: r8v0, types: [java.lang.Object, kotlinx.coroutines.channels.ProducerScope] */ /* JADX WARN: Type inference failed for: r8v2 */ /* JADX WARN: Type inference failed for: r8v5 */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final java.lang.Object invokeSuspend(java.lang.Object r12) throws java.lang.Throwable { /* r11 = this; java.lang.Object r0 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r1 = r11.label r2 = 0 r3 = 3 r4 = 2 r5 = 1 if (r1 == 0) goto L49 if (r1 == r5) goto L3b if (r1 == r4) goto L28 if (r1 != r3) goto L20 int r1 = r11.I$0 java.lang.Object r6 = r11.L$1 kotlinx.coroutines.channels.ChannelIterator r6 = (kotlinx.coroutines.channels.ChannelIterator) r6 java.lang.Object r7 = r11.L$0 kotlinx.coroutines.channels.ProducerScope r7 = (kotlinx.coroutines.channels.ProducerScope) r7 kotlin.ResultKt.throwOnFailure(r12) goto L5b L20: java.lang.IllegalStateException r11 = new java.lang.IllegalStateException java.lang.String r12 = "call to 'resume' before 'invoke' with coroutine" r11.(r12) throw r11 L28: int r1 = r11.I$0 java.lang.Object r6 = r11.L$2 java.lang.Object r7 = r11.L$1 kotlinx.coroutines.channels.ChannelIterator r7 = (kotlinx.coroutines.channels.ChannelIterator) r7 java.lang.Object r8 = r11.L$0 kotlinx.coroutines.channels.ProducerScope r8 = (kotlinx.coroutines.channels.ProducerScope) r8 kotlin.ResultKt.throwOnFailure(r12) r10 = r7 r7 = r6 r6 = r10 goto L98 L3b: int r1 = r11.I$0 java.lang.Object r6 = r11.L$1 kotlinx.coroutines.channels.ChannelIterator r6 = (kotlinx.coroutines.channels.ChannelIterator) r6 java.lang.Object r7 = r11.L$0 kotlinx.coroutines.channels.ProducerScope r7 = (kotlinx.coroutines.channels.ProducerScope) r7 kotlin.ResultKt.throwOnFailure(r12) goto L6f L49: kotlin.ResultKt.throwOnFailure(r12) java.lang.Object r12 = r11.L$0 kotlinx.coroutines.channels.ProducerScope r12 = (kotlinx.coroutines.channels.ProducerScope) r12 kotlinx.coroutines.channels.ReceiveChannel r1 = r11.$this_filterIndexed kotlinx.coroutines.channels.ChannelIterator r1 = r1.iterator() r6 = 0 r7 = r12 r10 = r6 r6 = r1 r1 = r10 L5b: r12 = r11 kotlin.coroutines.Continuation r12 = (kotlin.coroutines.Continuation) r12 r11.L$0 = r7 r11.L$1 = r6 r11.L$2 = r2 r11.I$0 = r1 r11.label = r5 java.lang.Object r12 = r6.hasNext(r12) if (r12 != r0) goto L6f return r0 L6f: java.lang.Boolean r12 = (java.lang.Boolean) r12 boolean r12 = r12.booleanValue() if (r12 == 0) goto Lb6 java.lang.Object r12 = r6.next() kotlin.jvm.functions.Function3, java.lang.Object> r8 = r11.$predicate int r9 = r1 + 1 java.lang.Integer r1 = kotlin.coroutines.jvm.internal.Boxing.boxInt(r1) r11.L$0 = r7 r11.L$1 = r6 r11.L$2 = r12 r11.I$0 = r9 r11.label = r4 java.lang.Object r1 = r8.invoke(r1, r12, r11) if (r1 != r0) goto L94 return r0 L94: r8 = r7 r7 = r12 r12 = r1 r1 = r9 L98: java.lang.Boolean r12 = (java.lang.Boolean) r12 boolean r12 = r12.booleanValue() if (r12 == 0) goto Lb4 r12 = r11 kotlin.coroutines.Continuation r12 = (kotlin.coroutines.Continuation) r12 r11.L$0 = r8 r11.L$1 = r6 r11.L$2 = r2 r11.I$0 = r1 r11.label = r3 java.lang.Object r12 = r8.send(r7, r12) if (r12 != r0) goto Lb4 return r0 Lb4: r7 = r8 goto L5b Lb6: kotlin.Unit r11 = kotlin.Unit.INSTANCE return r11 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00921.invokeSuspend(java.lang.Object):java.lang.Object"); } } @Deprecated(level = DeprecationLevel.HIDDEN, message = "Binary compatibility") public static final /* synthetic */ ReceiveChannel filterIndexed(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function3 function3) { return ProduceKt.produce$default(GlobalScope.INSTANCE, coroutineContext, 0, null, ChannelsKt.consumes(receiveChannel), new C00921(receiveChannel, function3, null), 6, null); } public static /* synthetic */ ReceiveChannel filterNot$default(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2 function2, int i, Object obj) { if ((i & 1) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return filterNot(receiveChannel, coroutineContext, function2); } /* JADX INFO: Add missing generic type declarations: [E] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filterNot$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(d1 = {"\u0000\n\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0002\u0010\u0000\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u00022\u0006\u0010\u0003\u001a\u0002H\u0002H\u008a@"}, d2 = {"", "", "E", LanguageUtils.ITALIAN_NAME}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filterNot$1", f = "Deprecated.kt", i = {}, l = {222}, m = "invokeSuspend", n = {}, s = {}) static final class C00931 extends SuspendLambda implements Function2, Object> { final /* synthetic */ Function2, Object> $predicate; /* 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 */ C00931(Function2, ? extends Object> function2, Continuation continuation) { super(2, continuation); this.$predicate = function2; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C00931 c00931 = new C00931(this.$predicate, continuation); c00931.L$0 = obj; return c00931; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(E e, Continuation continuation) { return ((C00931) create(e, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX ERROR: JadxRuntimeException in pass: ModVisitor jadx.core.utils.exceptions.JadxRuntimeException: Can't change immutable type java.lang.Object to kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filterNot$1 for r3v5 'this' java.lang.Object at jadx.core.dex.instructions.args.SSAVar.setType(SSAVar.java:114) at jadx.core.dex.instructions.args.RegisterArg.setType(RegisterArg.java:52) at jadx.core.dex.visitors.ModVisitor.removeCheckCast(ModVisitor.java:417) at jadx.core.dex.visitors.ModVisitor.replaceStep(ModVisitor.java:152) at jadx.core.dex.visitors.ModVisitor.visit(ModVisitor.java:96) */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final java.lang.Object invokeSuspend(java.lang.Object r4) { /* r3 = this; java.lang.Object r0 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r1 = r3.label r2 = 1 if (r1 == 0) goto L17 if (r1 != r2) goto Lf kotlin.ResultKt.throwOnFailure(r4) goto L27 Lf: java.lang.IllegalStateException r3 = new java.lang.IllegalStateException java.lang.String r4 = "call to 'resume' before 'invoke' with coroutine" r3.(r4) throw r3 L17: kotlin.ResultKt.throwOnFailure(r4) java.lang.Object r4 = r3.L$0 kotlin.jvm.functions.Function2, java.lang.Object> r1 = r3.$predicate r3.label = r2 java.lang.Object r4 = r1.invoke(r4, r3) if (r4 != r0) goto L27 return r0 L27: java.lang.Boolean r4 = (java.lang.Boolean) r4 boolean r3 = r4.booleanValue() r3 = r3 ^ r2 java.lang.Boolean r3 = kotlin.coroutines.jvm.internal.Boxing.boxBoolean(r3) return r3 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00931.invokeSuspend(java.lang.Object):java.lang.Object"); } } @Deprecated(level = DeprecationLevel.HIDDEN, message = "Binary compatibility") public static final /* synthetic */ ReceiveChannel filterNot(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2 function2) { return ChannelsKt.filter(receiveChannel, coroutineContext, new C00931(function2, null)); } /* JADX INFO: Add missing generic type declarations: [E] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filterNotNull$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(d1 = {"\u0000\u000e\n\u0000\n\u0002\u0010\u000b\n\u0000\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u00020\u0001\"\b\b\u0000\u0010\u0002*\u00020\u00032\b\u0010\u0004\u001a\u0004\u0018\u0001H\u0002H\u008a@"}, d2 = {"", "", "E", "", LanguageUtils.ITALIAN_NAME}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filterNotNull$1", f = "Deprecated.kt", i = {}, l = {}, m = "invokeSuspend", n = {}, s = {}) static final class C00941 extends SuspendLambda implements Function2, Object> { /* synthetic */ Object L$0; int label; C00941(Continuation continuation) { super(2, continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C00941 c00941 = new C00941(continuation); c00941.L$0 = obj; return c00941; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(E e, Continuation continuation) { return ((C00941) create(e, continuation)).invokeSuspend(Unit.INSTANCE); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) throws Throwable { IntrinsicsKt.getCOROUTINE_SUSPENDED(); if (this.label != 0) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } ResultKt.throwOnFailure(obj); return Boxing.boxBoolean(this.L$0 != null); } } public static final ReceiveChannel filterNotNull(ReceiveChannel receiveChannel) { return filter$default(receiveChannel, null, new C00941(null), 1, null); } /* JADX WARN: Removed duplicated region for block: B:23:0x005a A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:24:0x005b */ /* JADX WARN: Removed duplicated region for block: B:27:0x0066 A[Catch: all -> 0x0037, TryCatch #1 {all -> 0x0037, blocks: (B:12:0x0033, B:25:0x005e, B:27:0x0066, B:29:0x006c, B:21:0x004c, B:31:0x0071), top: B:42:0x0033 }] */ /* JADX WARN: Removed duplicated region for block: B:31:0x0071 A[Catch: all -> 0x0037, TRY_LEAVE, TryCatch #1 {all -> 0x0037, blocks: (B:12:0x0033, B:25:0x005e, B:27:0x0066, B:29:0x006c, B:21:0x004c, B:31:0x0071), top: B:42:0x0033 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:24:0x005b -> B:25:0x005e). Please report as a decompilation issue!!! */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object filterNotNullTo(kotlinx.coroutines.channels.ReceiveChannel r6, java.util.Collection r7, kotlin.coroutines.Continuation r8) throws java.lang.Throwable { /* boolean r0 = r8 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00951 if (r0 == 0) goto L14 r0 = r8 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filterNotNullTo$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00951) 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.channels.ChannelsKt__DeprecatedKt$filterNotNullTo$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filterNotNullTo$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 = 0 r4 = 1 if (r2 == 0) goto L41 if (r2 != r4) goto L39 java.lang.Object r6 = r0.L$2 kotlinx.coroutines.channels.ChannelIterator r6 = (kotlinx.coroutines.channels.ChannelIterator) r6 java.lang.Object r7 = r0.L$1 kotlinx.coroutines.channels.ReceiveChannel r7 = (kotlinx.coroutines.channels.ReceiveChannel) r7 java.lang.Object r2 = r0.L$0 java.util.Collection r2 = (java.util.Collection) r2 kotlin.ResultKt.throwOnFailure(r8) // Catch: java.lang.Throwable -> L37 goto L5e L37: r6 = move-exception goto L7b L39: java.lang.IllegalStateException r6 = new java.lang.IllegalStateException java.lang.String r7 = "call to 'resume' before 'invoke' with coroutine" r6.(r7) throw r6 L41: kotlin.ResultKt.throwOnFailure(r8) kotlinx.coroutines.channels.ChannelIterator r8 = r6.iterator() // Catch: java.lang.Throwable -> L77 r5 = r7 r7 = r6 r6 = r8 r8 = r5 L4c: r0.L$0 = r8 // Catch: java.lang.Throwable -> L37 r0.L$1 = r7 // Catch: java.lang.Throwable -> L37 r0.L$2 = r6 // Catch: java.lang.Throwable -> L37 r0.label = r4 // Catch: java.lang.Throwable -> L37 java.lang.Object r2 = r6.hasNext(r0) // Catch: java.lang.Throwable -> L37 if (r2 != r1) goto L5b return r1 L5b: r5 = r2 r2 = r8 r8 = r5 L5e: java.lang.Boolean r8 = (java.lang.Boolean) r8 // Catch: java.lang.Throwable -> L37 boolean r8 = r8.booleanValue() // Catch: java.lang.Throwable -> L37 if (r8 == 0) goto L71 java.lang.Object r8 = r6.next() // Catch: java.lang.Throwable -> L37 if (r8 == 0) goto L6f r2.add(r8) // Catch: java.lang.Throwable -> L37 L6f: r8 = r2 goto L4c L71: kotlin.Unit r6 = kotlin.Unit.INSTANCE // Catch: java.lang.Throwable -> L37 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r7, r3) return r2 L77: r7 = move-exception r5 = r7 r7 = r6 r6 = r5 L7b: throw r6 // Catch: java.lang.Throwable -> L7c L7c: r8 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r7, r6) throw r8 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.filterNotNullTo(kotlinx.coroutines.channels.ReceiveChannel, java.util.Collection, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Code restructure failed: missing block: B:51:0x0063, code lost: r9 = r0; r0 = r2; */ /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:31:0x007e A[Catch: all -> 0x009c, TryCatch #2 {all -> 0x009c, blocks: (B:25:0x0063, B:29:0x0076, B:31:0x007e, B:33:0x0084, B:37:0x0096, B:24:0x005f), top: B:49:0x005f }] */ /* JADX WARN: Removed duplicated region for block: B:36:0x0093 */ /* JADX WARN: Removed duplicated region for block: B:37:0x0096 A[Catch: all -> 0x009c, TRY_LEAVE, TryCatch #2 {all -> 0x009c, blocks: (B:25:0x0063, B:29:0x0076, B:31:0x007e, B:33:0x0084, B:37:0x0096, B:24:0x005f), top: B:49:0x005f }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Type inference failed for: r8v0, types: [kotlinx.coroutines.channels.SendChannel] */ /* JADX WARN: Type inference failed for: r8v10 */ /* JADX WARN: Type inference failed for: r8v11, types: [java.lang.Object, kotlinx.coroutines.channels.SendChannel] */ /* JADX WARN: Type inference failed for: r8v12, types: [java.lang.Object] */ /* JADX WARN: Type inference failed for: r8v13 */ /* JADX WARN: Type inference failed for: r8v3 */ /* JADX WARN: Type inference failed for: r8v7 */ /* JADX WARN: Type inference failed for: r8v8, types: [kotlinx.coroutines.channels.ReceiveChannel] */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object filterNotNullTo(kotlinx.coroutines.channels.ReceiveChannel r7, kotlinx.coroutines.channels.SendChannel r8, kotlin.coroutines.Continuation r9) throws java.lang.Throwable { /* boolean r0 = r9 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.AnonymousClass3 if (r0 == 0) goto L14 r0 = r9 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filterNotNullTo$3 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.AnonymousClass3) 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.channels.ChannelsKt__DeprecatedKt$filterNotNullTo$3 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$filterNotNullTo$3 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 r5 = 0 if (r2 == 0) goto L5c if (r2 == r4) goto L45 if (r2 != r3) goto L3d java.lang.Object r7 = r0.L$2 kotlinx.coroutines.channels.ChannelIterator r7 = (kotlinx.coroutines.channels.ChannelIterator) r7 java.lang.Object r8 = r0.L$1 kotlinx.coroutines.channels.ReceiveChannel r8 = (kotlinx.coroutines.channels.ReceiveChannel) r8 java.lang.Object r2 = r0.L$0 kotlinx.coroutines.channels.SendChannel r2 = (kotlinx.coroutines.channels.SendChannel) r2 kotlin.ResultKt.throwOnFailure(r9) // Catch: java.lang.Throwable -> L5a r9 = r7 r7 = r8 r8 = r2 goto L63 L3d: java.lang.IllegalStateException r7 = new java.lang.IllegalStateException java.lang.String r8 = "call to 'resume' before 'invoke' with coroutine" r7.(r8) throw r7 L45: java.lang.Object r7 = r0.L$2 kotlinx.coroutines.channels.ChannelIterator r7 = (kotlinx.coroutines.channels.ChannelIterator) r7 java.lang.Object r8 = r0.L$1 kotlinx.coroutines.channels.ReceiveChannel r8 = (kotlinx.coroutines.channels.ReceiveChannel) r8 java.lang.Object r2 = r0.L$0 kotlinx.coroutines.channels.SendChannel r2 = (kotlinx.coroutines.channels.SendChannel) r2 kotlin.ResultKt.throwOnFailure(r9) // Catch: java.lang.Throwable -> L5a r6 = r0 r0 = r7 r7 = r8 r8 = r2 L58: r2 = r6 goto L76 L5a: r7 = move-exception goto La0 L5c: kotlin.ResultKt.throwOnFailure(r9) kotlinx.coroutines.channels.ChannelIterator r9 = r7.iterator() // Catch: java.lang.Throwable -> L9c L63: r0.L$0 = r8 // Catch: java.lang.Throwable -> L9c r0.L$1 = r7 // Catch: java.lang.Throwable -> L9c r0.L$2 = r9 // Catch: java.lang.Throwable -> L9c r0.label = r4 // Catch: java.lang.Throwable -> L9c java.lang.Object r2 = r9.hasNext(r0) // Catch: java.lang.Throwable -> L9c if (r2 != r1) goto L72 return r1 L72: r6 = r0 r0 = r9 r9 = r2 goto L58 L76: java.lang.Boolean r9 = (java.lang.Boolean) r9 // Catch: java.lang.Throwable -> L9c boolean r9 = r9.booleanValue() // Catch: java.lang.Throwable -> L9c if (r9 == 0) goto L96 java.lang.Object r9 = r0.next() // Catch: java.lang.Throwable -> L9c if (r9 == 0) goto L93 r2.L$0 = r8 // Catch: java.lang.Throwable -> L9c r2.L$1 = r7 // Catch: java.lang.Throwable -> L9c r2.L$2 = r0 // Catch: java.lang.Throwable -> L9c r2.label = r3 // Catch: java.lang.Throwable -> L9c java.lang.Object r9 = r8.send(r9, r2) // Catch: java.lang.Throwable -> L9c if (r9 != r1) goto L93 return r1 L93: r9 = r0 r0 = r2 goto L63 L96: kotlin.Unit r9 = kotlin.Unit.INSTANCE // Catch: java.lang.Throwable -> L9c kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r7, r5) return r8 L9c: r8 = move-exception r6 = r8 r8 = r7 r7 = r6 La0: throw r7 // Catch: java.lang.Throwable -> La1 La1: r9 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r8, r7) throw r9 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.filterNotNullTo(kotlinx.coroutines.channels.ReceiveChannel, kotlinx.coroutines.channels.SendChannel, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX INFO: Add missing generic type declarations: [E] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$take$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(d1 = {"\u0000\f\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\u0010\u0000\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u0002*\b\u0012\u0004\u0012\u0002H\u00020\u0003H\u008a@"}, d2 = {"", "", "E", "Lkotlinx/coroutines/channels/ProducerScope;"}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$take$1", f = "Deprecated.kt", i = {0, 0, 1, 1}, l = {254, 255}, m = "invokeSuspend", n = {"$this$produce", "remaining", "$this$produce", "remaining"}, s = {"L$0", "I$0", "L$0", "I$0"}) static final class C01111 extends SuspendLambda implements Function2, Continuation, Object> { final /* synthetic */ int $n; final /* synthetic */ ReceiveChannel $this_take; int I$0; private /* synthetic */ Object L$0; Object L$1; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ /* JADX WARN: Multi-variable type inference failed */ C01111(int i, ReceiveChannel receiveChannel, Continuation continuation) { super(2, continuation); this.$n = i; this.$this_take = receiveChannel; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C01111 c01111 = new C01111(this.$n, this.$this_take, continuation); c01111.L$0 = obj; return c01111; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(ProducerScope producerScope, Continuation continuation) { return ((C01111) create(producerScope, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX WARN: Removed duplicated region for block: B:22:0x005f A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:23:0x0060 */ /* JADX WARN: Removed duplicated region for block: B:26:0x006b */ /* JADX WARN: Removed duplicated region for block: B:31:0x0085 */ /* JADX WARN: Removed duplicated region for block: B:33:0x0088 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:27:0x007e -> B:7:0x001b). Please report as a decompilation issue!!! */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final java.lang.Object invokeSuspend(java.lang.Object r9) throws java.lang.Throwable { /* r8 = this; java.lang.Object r0 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r1 = r8.label r2 = 2 r3 = 1 if (r1 == 0) goto L33 if (r1 == r3) goto L25 if (r1 != r2) goto L1d int r1 = r8.I$0 java.lang.Object r4 = r8.L$1 kotlinx.coroutines.channels.ChannelIterator r4 = (kotlinx.coroutines.channels.ChannelIterator) r4 java.lang.Object r5 = r8.L$0 kotlinx.coroutines.channels.ProducerScope r5 = (kotlinx.coroutines.channels.ProducerScope) r5 kotlin.ResultKt.throwOnFailure(r9) L1b: r9 = r5 goto L81 L1d: java.lang.IllegalStateException r8 = new java.lang.IllegalStateException java.lang.String r9 = "call to 'resume' before 'invoke' with coroutine" r8.(r9) throw r8 L25: int r1 = r8.I$0 java.lang.Object r4 = r8.L$1 kotlinx.coroutines.channels.ChannelIterator r4 = (kotlinx.coroutines.channels.ChannelIterator) r4 java.lang.Object r5 = r8.L$0 kotlinx.coroutines.channels.ProducerScope r5 = (kotlinx.coroutines.channels.ProducerScope) r5 kotlin.ResultKt.throwOnFailure(r9) goto L63 L33: kotlin.ResultKt.throwOnFailure(r9) java.lang.Object r9 = r8.L$0 kotlinx.coroutines.channels.ProducerScope r9 = (kotlinx.coroutines.channels.ProducerScope) r9 int r1 = r8.$n if (r1 != 0) goto L41 kotlin.Unit r8 = kotlin.Unit.INSTANCE return r8 L41: if (r1 < 0) goto L45 r4 = r3 goto L46 L45: r4 = 0 L46: if (r4 == 0) goto L8b kotlinx.coroutines.channels.ReceiveChannel r4 = r8.$this_take kotlinx.coroutines.channels.ChannelIterator r4 = r4.iterator() L4e: r5 = r8 kotlin.coroutines.Continuation r5 = (kotlin.coroutines.Continuation) r5 r8.L$0 = r9 r8.L$1 = r4 r8.I$0 = r1 r8.label = r3 java.lang.Object r5 = r4.hasNext(r5) if (r5 != r0) goto L60 return r0 L60: r7 = r5 r5 = r9 r9 = r7 L63: java.lang.Boolean r9 = (java.lang.Boolean) r9 boolean r9 = r9.booleanValue() if (r9 == 0) goto L88 java.lang.Object r9 = r4.next() r6 = r8 kotlin.coroutines.Continuation r6 = (kotlin.coroutines.Continuation) r6 r8.L$0 = r5 r8.L$1 = r4 r8.I$0 = r1 r8.label = r2 java.lang.Object r9 = r5.send(r9, r6) if (r9 != r0) goto L1b return r0 L81: int r1 = r1 + (-1) if (r1 != 0) goto L4e kotlin.Unit r8 = kotlin.Unit.INSTANCE return r8 L88: kotlin.Unit r8 = kotlin.Unit.INSTANCE return r8 L8b: java.lang.StringBuilder r8 = new java.lang.StringBuilder java.lang.String r9 = "Requested element count " r8.(r9) java.lang.StringBuilder r8 = r8.append(r1) java.lang.String r9 = " is less than zero." java.lang.StringBuilder r8 = r8.append(r9) java.lang.String r8 = r8.toString() java.lang.IllegalArgumentException r9 = new java.lang.IllegalArgumentException java.lang.String r8 = r8.toString() r9.(r8) throw r9 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01111.invokeSuspend(java.lang.Object):java.lang.Object"); } } public static /* synthetic */ ReceiveChannel take$default(ReceiveChannel receiveChannel, int i, CoroutineContext coroutineContext, int i2, Object obj) { if ((i2 & 2) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return take(receiveChannel, i, coroutineContext); } @Deprecated(level = DeprecationLevel.HIDDEN, message = "Binary compatibility") public static final /* synthetic */ ReceiveChannel take(ReceiveChannel receiveChannel, int i, CoroutineContext coroutineContext) { return ProduceKt.produce$default(GlobalScope.INSTANCE, coroutineContext, 0, null, ChannelsKt.consumes(receiveChannel), new C01111(i, receiveChannel, null), 6, null); } public static /* synthetic */ ReceiveChannel takeWhile$default(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2 function2, int i, Object obj) { if ((i & 1) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return takeWhile(receiveChannel, coroutineContext, function2); } /* JADX INFO: Add missing generic type declarations: [E] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$takeWhile$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(d1 = {"\u0000\f\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\u0010\u0000\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u0002*\b\u0012\u0004\u0012\u0002H\u00020\u0003H\u008a@"}, d2 = {"", "", "E", "Lkotlinx/coroutines/channels/ProducerScope;"}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$takeWhile$1", f = "Deprecated.kt", i = {0, 1, 1, 2}, l = {269, 270, 271}, m = "invokeSuspend", n = {"$this$produce", "$this$produce", "e", "$this$produce"}, s = {"L$0", "L$0", "L$2", "L$0"}) static final class C01121 extends SuspendLambda implements Function2, Continuation, Object> { final /* synthetic */ Function2, Object> $predicate; final /* synthetic */ ReceiveChannel $this_takeWhile; private /* synthetic */ Object L$0; Object L$1; Object L$2; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ /* JADX WARN: Multi-variable type inference failed */ C01121(ReceiveChannel receiveChannel, Function2, ? extends Object> function2, Continuation continuation) { super(2, continuation); this.$this_takeWhile = receiveChannel; this.$predicate = function2; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C01121 c01121 = new C01121(this.$this_takeWhile, this.$predicate, continuation); c01121.L$0 = obj; return c01121; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(ProducerScope producerScope, Continuation continuation) { return ((C01121) create(producerScope, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:18:0x0065 */ /* JADX WARN: Removed duplicated region for block: B:24:0x0087 */ /* JADX WARN: Removed duplicated region for block: B:26:0x008a */ /* JADX WARN: Removed duplicated region for block: B:30:0x00a0 */ /* JADX WARN: Type inference failed for: r5v0 */ /* JADX WARN: Type inference failed for: r5v12 */ /* JADX WARN: Type inference failed for: r5v13 */ /* JADX WARN: Type inference failed for: r5v14 */ /* JADX WARN: Type inference failed for: r5v2 */ /* JADX WARN: Type inference failed for: r5v3, types: [java.lang.Object] */ /* JADX WARN: Type inference failed for: r5v5, types: [java.lang.Object] */ /* JADX WARN: Type inference failed for: r6v0, types: [java.lang.Object, kotlinx.coroutines.channels.ProducerScope] */ /* JADX WARN: Type inference failed for: r6v3 */ /* JADX WARN: Type inference failed for: r6v6 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:29:0x009d -> B:13:0x004d). Please report as a decompilation issue!!! */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final java.lang.Object invokeSuspend(java.lang.Object r10) throws java.lang.Throwable { /* r9 = this; java.lang.Object r0 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r1 = r9.label r2 = 3 r3 = 2 r4 = 1 if (r1 == 0) goto L3f if (r1 == r4) goto L33 if (r1 == r3) goto L25 if (r1 != r2) goto L1d java.lang.Object r1 = r9.L$1 kotlinx.coroutines.channels.ChannelIterator r1 = (kotlinx.coroutines.channels.ChannelIterator) r1 java.lang.Object r5 = r9.L$0 kotlinx.coroutines.channels.ProducerScope r5 = (kotlinx.coroutines.channels.ProducerScope) r5 kotlin.ResultKt.throwOnFailure(r10) goto L4d L1d: java.lang.IllegalStateException r9 = new java.lang.IllegalStateException java.lang.String r10 = "call to 'resume' before 'invoke' with coroutine" r9.(r10) throw r9 L25: java.lang.Object r1 = r9.L$2 java.lang.Object r5 = r9.L$1 kotlinx.coroutines.channels.ChannelIterator r5 = (kotlinx.coroutines.channels.ChannelIterator) r5 java.lang.Object r6 = r9.L$0 kotlinx.coroutines.channels.ProducerScope r6 = (kotlinx.coroutines.channels.ProducerScope) r6 kotlin.ResultKt.throwOnFailure(r10) goto L7f L33: java.lang.Object r1 = r9.L$1 kotlinx.coroutines.channels.ChannelIterator r1 = (kotlinx.coroutines.channels.ChannelIterator) r1 java.lang.Object r5 = r9.L$0 kotlinx.coroutines.channels.ProducerScope r5 = (kotlinx.coroutines.channels.ProducerScope) r5 kotlin.ResultKt.throwOnFailure(r10) goto L5d L3f: kotlin.ResultKt.throwOnFailure(r10) java.lang.Object r10 = r9.L$0 kotlinx.coroutines.channels.ProducerScope r10 = (kotlinx.coroutines.channels.ProducerScope) r10 kotlinx.coroutines.channels.ReceiveChannel r1 = r9.$this_takeWhile kotlinx.coroutines.channels.ChannelIterator r1 = r1.iterator() r5 = r10 L4d: r10 = r9 kotlin.coroutines.Continuation r10 = (kotlin.coroutines.Continuation) r10 r9.L$0 = r5 r9.L$1 = r1 r9.label = r4 java.lang.Object r10 = r1.hasNext(r10) if (r10 != r0) goto L5d return r0 L5d: java.lang.Boolean r10 = (java.lang.Boolean) r10 boolean r10 = r10.booleanValue() if (r10 == 0) goto La0 java.lang.Object r10 = r1.next() kotlin.jvm.functions.Function2, java.lang.Object> r6 = r9.$predicate r9.L$0 = r5 r9.L$1 = r1 r9.L$2 = r10 r9.label = r3 java.lang.Object r6 = r6.invoke(r10, r9) if (r6 != r0) goto L7a return r0 L7a: r8 = r1 r1 = r10 r10 = r6 r6 = r5 r5 = r8 L7f: java.lang.Boolean r10 = (java.lang.Boolean) r10 boolean r10 = r10.booleanValue() if (r10 != 0) goto L8a kotlin.Unit r9 = kotlin.Unit.INSTANCE return r9 L8a: r10 = r9 kotlin.coroutines.Continuation r10 = (kotlin.coroutines.Continuation) r10 r9.L$0 = r6 r9.L$1 = r5 r7 = 0 r9.L$2 = r7 r9.label = r2 java.lang.Object r10 = r6.send(r1, r10) if (r10 != r0) goto L9d return r0 L9d: r1 = r5 r5 = r6 goto L4d La0: kotlin.Unit r9 = kotlin.Unit.INSTANCE return r9 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01121.invokeSuspend(java.lang.Object):java.lang.Object"); } } @Deprecated(level = DeprecationLevel.HIDDEN, message = "Binary compatibility") public static final /* synthetic */ ReceiveChannel takeWhile(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2 function2) { return ProduceKt.produce$default(GlobalScope.INSTANCE, coroutineContext, 0, null, ChannelsKt.consumes(receiveChannel), new C01121(receiveChannel, function2, null), 6, null); } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:26:0x006c A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:27:0x006d */ /* JADX WARN: Removed duplicated region for block: B:30:0x007a A[Catch: all -> 0x0055, TryCatch #1 {all -> 0x0055, blocks: (B:13:0x0036, B:28:0x0072, B:30:0x007a, B:33:0x008d, B:18:0x0051), top: B:44:0x0024 }] */ /* JADX WARN: Removed duplicated region for block: B:33:0x008d A[Catch: all -> 0x0055, TRY_LEAVE, TryCatch #1 {all -> 0x0055, blocks: (B:13:0x0036, B:28:0x0072, B:30:0x007a, B:33:0x008d, B:18:0x0051), top: B:44:0x0024 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Type inference failed for: r2v1, types: [java.lang.Object, kotlinx.coroutines.channels.SendChannel] */ /* JADX WARN: Type inference failed for: r2v10 */ /* JADX WARN: Type inference failed for: r2v11 */ /* JADX WARN: Type inference failed for: r2v3 */ /* JADX WARN: Type inference failed for: r2v4 */ /* JADX WARN: Type inference failed for: r2v9 */ /* JADX WARN: Type inference failed for: r6v1 */ /* JADX WARN: Type inference failed for: r7v18 */ /* JADX WARN: Type inference failed for: r8v0, types: [C extends kotlinx.coroutines.channels.SendChannel] */ /* JADX WARN: Type inference failed for: r8v1 */ /* JADX WARN: Type inference failed for: r8v18 */ /* JADX WARN: Type inference failed for: r8v2, types: [kotlinx.coroutines.channels.ReceiveChannel] */ /* JADX WARN: Type inference failed for: r8v21 */ /* JADX WARN: Type inference failed for: r8v22 */ /* JADX WARN: Type inference failed for: r8v23 */ /* JADX WARN: Type inference failed for: r8v24 */ /* JADX WARN: Type inference failed for: r8v25 */ /* JADX WARN: Type inference failed for: r8v26 */ /* JADX WARN: Type inference failed for: r8v4 */ /* JADX WARN: Type inference failed for: r8v5, types: [java.lang.Object, kotlinx.coroutines.channels.ReceiveChannel] */ /* JADX WARN: Type inference failed for: r8v6, types: [java.lang.Object] */ /* JADX WARN: Type inference failed for: r8v8 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:31:0x008a -> B:14:0x0039). Please report as a decompilation issue!!! */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final > java.lang.Object toChannel(kotlinx.coroutines.channels.ReceiveChannel r7, C r8, kotlin.coroutines.Continuation r9) throws java.lang.Throwable { /* boolean r0 = r9 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01131 if (r0 == 0) goto L14 r0 = r9 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$toChannel$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01131) 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.channels.ChannelsKt__DeprecatedKt$toChannel$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$toChannel$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 r5 = 0 if (r2 == 0) goto L57 if (r2 == r4) goto L45 if (r2 != r3) goto L3d java.lang.Object r7 = r0.L$2 kotlinx.coroutines.channels.ChannelIterator r7 = (kotlinx.coroutines.channels.ChannelIterator) r7 java.lang.Object r8 = r0.L$1 kotlinx.coroutines.channels.ReceiveChannel r8 = (kotlinx.coroutines.channels.ReceiveChannel) r8 java.lang.Object r2 = r0.L$0 kotlinx.coroutines.channels.SendChannel r2 = (kotlinx.coroutines.channels.SendChannel) r2 kotlin.ResultKt.throwOnFailure(r9) // Catch: java.lang.Throwable -> L55 L39: r9 = r7 r7 = r8 r8 = r2 goto L5e L3d: java.lang.IllegalStateException r7 = new java.lang.IllegalStateException java.lang.String r8 = "call to 'resume' before 'invoke' with coroutine" r7.(r8) throw r7 L45: java.lang.Object r7 = r0.L$2 kotlinx.coroutines.channels.ChannelIterator r7 = (kotlinx.coroutines.channels.ChannelIterator) r7 java.lang.Object r8 = r0.L$1 kotlinx.coroutines.channels.ReceiveChannel r8 = (kotlinx.coroutines.channels.ReceiveChannel) r8 java.lang.Object r2 = r0.L$0 kotlinx.coroutines.channels.SendChannel r2 = (kotlinx.coroutines.channels.SendChannel) r2 kotlin.ResultKt.throwOnFailure(r9) // Catch: java.lang.Throwable -> L55 goto L72 L55: r7 = move-exception goto L97 L57: kotlin.ResultKt.throwOnFailure(r9) kotlinx.coroutines.channels.ChannelIterator r9 = r7.iterator() // Catch: java.lang.Throwable -> L93 L5e: r0.L$0 = r8 // Catch: java.lang.Throwable -> L93 r0.L$1 = r7 // Catch: java.lang.Throwable -> L93 r0.L$2 = r9 // Catch: java.lang.Throwable -> L93 r0.label = r4 // Catch: java.lang.Throwable -> L93 java.lang.Object r2 = r9.hasNext(r0) // Catch: java.lang.Throwable -> L93 if (r2 != r1) goto L6d return r1 L6d: r6 = r8 r8 = r7 r7 = r9 r9 = r2 r2 = r6 L72: java.lang.Boolean r9 = (java.lang.Boolean) r9 // Catch: java.lang.Throwable -> L55 boolean r9 = r9.booleanValue() // Catch: java.lang.Throwable -> L55 if (r9 == 0) goto L8d java.lang.Object r9 = r7.next() // Catch: java.lang.Throwable -> L55 r0.L$0 = r2 // Catch: java.lang.Throwable -> L55 r0.L$1 = r8 // Catch: java.lang.Throwable -> L55 r0.L$2 = r7 // Catch: java.lang.Throwable -> L55 r0.label = r3 // Catch: java.lang.Throwable -> L55 java.lang.Object r9 = r2.send(r9, r0) // Catch: java.lang.Throwable -> L55 if (r9 != r1) goto L39 return r1 L8d: kotlin.Unit r7 = kotlin.Unit.INSTANCE // Catch: java.lang.Throwable -> L55 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r8, r5) return r2 L93: r8 = move-exception r6 = r8 r8 = r7 r7 = r6 L97: throw r7 // Catch: java.lang.Throwable -> L98 L98: r9 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r8, r7) throw r9 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.toChannel(kotlinx.coroutines.channels.ReceiveChannel, kotlinx.coroutines.channels.SendChannel, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:23:0x005a A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:24:0x005b */ /* JADX WARN: Removed duplicated region for block: B:27:0x0066 A[Catch: all -> 0x0037, TryCatch #1 {all -> 0x0037, blocks: (B:12:0x0033, B:25:0x005e, B:27:0x0066, B:21:0x004c, B:28:0x006f), top: B:39:0x0033 }] */ /* JADX WARN: Removed duplicated region for block: B:28:0x006f A[Catch: all -> 0x0037, TRY_LEAVE, TryCatch #1 {all -> 0x0037, blocks: (B:12:0x0033, B:25:0x005e, B:27:0x0066, B:21:0x004c, B:28:0x006f), top: B:39:0x0033 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Type inference failed for: r2v2 */ /* JADX WARN: Type inference failed for: r2v3, types: [java.lang.Object, java.util.Collection] */ /* JADX WARN: Type inference failed for: r2v6 */ /* JADX WARN: Type inference failed for: r8v11 */ /* JADX WARN: Type inference failed for: r8v3 */ /* JADX WARN: Type inference failed for: r8v5, types: [java.lang.Object] */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:24:0x005b -> B:25:0x005e). Please report as a decompilation issue!!! */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final > java.lang.Object toCollection(kotlinx.coroutines.channels.ReceiveChannel r6, C r7, kotlin.coroutines.Continuation r8) throws java.lang.Throwable { /* boolean r0 = r8 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01141 if (r0 == 0) goto L14 r0 = r8 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$toCollection$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01141) 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.channels.ChannelsKt__DeprecatedKt$toCollection$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$toCollection$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 = 0 r4 = 1 if (r2 == 0) goto L41 if (r2 != r4) goto L39 java.lang.Object r6 = r0.L$2 kotlinx.coroutines.channels.ChannelIterator r6 = (kotlinx.coroutines.channels.ChannelIterator) r6 java.lang.Object r7 = r0.L$1 kotlinx.coroutines.channels.ReceiveChannel r7 = (kotlinx.coroutines.channels.ReceiveChannel) r7 java.lang.Object r2 = r0.L$0 java.util.Collection r2 = (java.util.Collection) r2 kotlin.ResultKt.throwOnFailure(r8) // Catch: java.lang.Throwable -> L37 goto L5e L37: r6 = move-exception goto L79 L39: java.lang.IllegalStateException r6 = new java.lang.IllegalStateException java.lang.String r7 = "call to 'resume' before 'invoke' with coroutine" r6.(r7) throw r6 L41: kotlin.ResultKt.throwOnFailure(r8) kotlinx.coroutines.channels.ChannelIterator r8 = r6.iterator() // Catch: java.lang.Throwable -> L75 r5 = r7 r7 = r6 r6 = r8 r8 = r5 L4c: r0.L$0 = r8 // Catch: java.lang.Throwable -> L37 r0.L$1 = r7 // Catch: java.lang.Throwable -> L37 r0.L$2 = r6 // Catch: java.lang.Throwable -> L37 r0.label = r4 // Catch: java.lang.Throwable -> L37 java.lang.Object r2 = r6.hasNext(r0) // Catch: java.lang.Throwable -> L37 if (r2 != r1) goto L5b return r1 L5b: r5 = r2 r2 = r8 r8 = r5 L5e: java.lang.Boolean r8 = (java.lang.Boolean) r8 // Catch: java.lang.Throwable -> L37 boolean r8 = r8.booleanValue() // Catch: java.lang.Throwable -> L37 if (r8 == 0) goto L6f java.lang.Object r8 = r6.next() // Catch: java.lang.Throwable -> L37 r2.add(r8) // Catch: java.lang.Throwable -> L37 r8 = r2 goto L4c L6f: kotlin.Unit r6 = kotlin.Unit.INSTANCE // Catch: java.lang.Throwable -> L37 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r7, r3) return r2 L75: r7 = move-exception r5 = r7 r7 = r6 r6 = r5 L79: throw r6 // Catch: java.lang.Throwable -> L7a L7a: r8 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r7, r6) throw r8 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.toCollection(kotlinx.coroutines.channels.ReceiveChannel, java.util.Collection, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:23:0x005a A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:24:0x005b */ /* JADX WARN: Removed duplicated region for block: B:27:0x0066 A[Catch: all -> 0x0037, TryCatch #1 {all -> 0x0037, blocks: (B:12:0x0033, B:25:0x005e, B:27:0x0066, B:21:0x004c, B:28:0x0079), top: B:39:0x0033 }] */ /* JADX WARN: Removed duplicated region for block: B:28:0x0079 A[Catch: all -> 0x0037, TRY_LEAVE, TryCatch #1 {all -> 0x0037, blocks: (B:12:0x0033, B:25:0x005e, B:27:0x0066, B:21:0x004c, B:28:0x0079), top: B:39:0x0033 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Type inference failed for: r2v2 */ /* JADX WARN: Type inference failed for: r2v3, types: [java.lang.Object, java.util.Map] */ /* JADX WARN: Type inference failed for: r2v6 */ /* JADX WARN: Type inference failed for: r9v13 */ /* JADX WARN: Type inference failed for: r9v3 */ /* JADX WARN: Type inference failed for: r9v5, types: [java.lang.Object] */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:24:0x005b -> B:25:0x005e). Please report as a decompilation issue!!! */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final > java.lang.Object toMap(kotlinx.coroutines.channels.ReceiveChannel> r7, M r8, kotlin.coroutines.Continuation r9) throws java.lang.Throwable { /* boolean r0 = r9 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.AnonymousClass2 if (r0 == 0) goto L14 r0 = r9 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$toMap$2 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.AnonymousClass2) 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.channels.ChannelsKt__DeprecatedKt$toMap$2 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$toMap$2 r0.(r9) L19: java.lang.Object r9 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 0 r4 = 1 if (r2 == 0) goto L41 if (r2 != r4) goto L39 java.lang.Object r7 = r0.L$2 kotlinx.coroutines.channels.ChannelIterator r7 = (kotlinx.coroutines.channels.ChannelIterator) r7 java.lang.Object r8 = r0.L$1 kotlinx.coroutines.channels.ReceiveChannel r8 = (kotlinx.coroutines.channels.ReceiveChannel) r8 java.lang.Object r2 = r0.L$0 java.util.Map r2 = (java.util.Map) r2 kotlin.ResultKt.throwOnFailure(r9) // Catch: java.lang.Throwable -> L37 goto L5e L37: r7 = move-exception goto L83 L39: java.lang.IllegalStateException r7 = new java.lang.IllegalStateException java.lang.String r8 = "call to 'resume' before 'invoke' with coroutine" r7.(r8) throw r7 L41: kotlin.ResultKt.throwOnFailure(r9) kotlinx.coroutines.channels.ChannelIterator r9 = r7.iterator() // Catch: java.lang.Throwable -> L7f r6 = r8 r8 = r7 r7 = r9 r9 = r6 L4c: r0.L$0 = r9 // Catch: java.lang.Throwable -> L37 r0.L$1 = r8 // Catch: java.lang.Throwable -> L37 r0.L$2 = r7 // Catch: java.lang.Throwable -> L37 r0.label = r4 // Catch: java.lang.Throwable -> L37 java.lang.Object r2 = r7.hasNext(r0) // Catch: java.lang.Throwable -> L37 if (r2 != r1) goto L5b return r1 L5b: r6 = r2 r2 = r9 r9 = r6 L5e: java.lang.Boolean r9 = (java.lang.Boolean) r9 // Catch: java.lang.Throwable -> L37 boolean r9 = r9.booleanValue() // Catch: java.lang.Throwable -> L37 if (r9 == 0) goto L79 java.lang.Object r9 = r7.next() // Catch: java.lang.Throwable -> L37 kotlin.Pair r9 = (kotlin.Pair) r9 // Catch: java.lang.Throwable -> L37 java.lang.Object r5 = r9.getFirst() // Catch: java.lang.Throwable -> L37 java.lang.Object r9 = r9.getSecond() // Catch: java.lang.Throwable -> L37 r2.put(r5, r9) // Catch: java.lang.Throwable -> L37 r9 = r2 goto L4c L79: kotlin.Unit r7 = kotlin.Unit.INSTANCE // Catch: java.lang.Throwable -> L37 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r8, r3) return r2 L7f: r8 = move-exception r6 = r8 r8 = r7 r7 = r6 L83: throw r7 // Catch: java.lang.Throwable -> L84 L84: r9 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r8, r7) throw r9 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.toMap(kotlinx.coroutines.channels.ReceiveChannel, java.util.Map, kotlin.coroutines.Continuation):java.lang.Object"); } public static /* synthetic */ ReceiveChannel flatMap$default(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2 function2, int i, Object obj) { if ((i & 1) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return flatMap(receiveChannel, coroutineContext, function2); } /* JADX INFO: Add missing generic type declarations: [R] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$flatMap$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.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 = {"", "", "E", "R", "Lkotlinx/coroutines/channels/ProducerScope;"}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$flatMap$1", f = "Deprecated.kt", i = {0, 1, 2}, l = {321, 322, 322}, m = "invokeSuspend", n = {"$this$produce", "$this$produce", "$this$produce"}, s = {"L$0", "L$0", "L$0"}) static final class C00981 extends SuspendLambda implements Function2, Continuation, Object> { final /* synthetic */ ReceiveChannel $this_flatMap; final /* synthetic */ Function2>, Object> $transform; private /* synthetic */ Object L$0; Object L$1; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ /* JADX WARN: Multi-variable type inference failed */ C00981(ReceiveChannel receiveChannel, Function2>, ? extends Object> function2, Continuation continuation) { super(2, continuation); this.$this_flatMap = receiveChannel; this.$transform = function2; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C00981 c00981 = new C00981(this.$this_flatMap, this.$transform, continuation); c00981.L$0 = obj; return c00981; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(ProducerScope producerScope, Continuation continuation) { return ((C00981) create(producerScope, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX WARN: Type inference incomplete: some casts might be missing */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:22:0x0088 -> B:13:0x004b). Please report as a decompilation issue!!! */ /* JADX ERROR: JadxRuntimeException in pass: ModVisitor jadx.core.utils.exceptions.JadxRuntimeException: Can't change immutable type java.lang.Object to kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$flatMap$1 for r8v3 'this' java.lang.Object at jadx.core.dex.instructions.args.SSAVar.setType(SSAVar.java:114) at jadx.core.dex.instructions.args.RegisterArg.setType(RegisterArg.java:52) at jadx.core.dex.visitors.ModVisitor.removeCheckCast(ModVisitor.java:417) at jadx.core.dex.visitors.ModVisitor.replaceStep(ModVisitor.java:152) at jadx.core.dex.visitors.ModVisitor.visit(ModVisitor.java:96) */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final java.lang.Object invokeSuspend(java.lang.Object r9) { /* r8 = this; java.lang.Object r0 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r1 = r8.label r2 = 3 r3 = 2 r4 = 1 if (r1 == 0) goto L3d if (r1 == r4) goto L31 if (r1 == r3) goto L25 if (r1 != r2) goto L1d java.lang.Object r1 = r8.L$1 kotlinx.coroutines.channels.ChannelIterator r1 = (kotlinx.coroutines.channels.ChannelIterator) r1 java.lang.Object r5 = r8.L$0 kotlinx.coroutines.channels.ProducerScope r5 = (kotlinx.coroutines.channels.ProducerScope) r5 kotlin.ResultKt.throwOnFailure(r9) goto L4b L1d: java.lang.IllegalStateException r8 = new java.lang.IllegalStateException java.lang.String r9 = "call to 'resume' before 'invoke' with coroutine" r8.(r9) throw r8 L25: java.lang.Object r1 = r8.L$1 kotlinx.coroutines.channels.ChannelIterator r1 = (kotlinx.coroutines.channels.ChannelIterator) r1 java.lang.Object r5 = r8.L$0 kotlinx.coroutines.channels.ProducerScope r5 = (kotlinx.coroutines.channels.ProducerScope) r5 kotlin.ResultKt.throwOnFailure(r9) goto L76 L31: java.lang.Object r1 = r8.L$1 kotlinx.coroutines.channels.ChannelIterator r1 = (kotlinx.coroutines.channels.ChannelIterator) r1 java.lang.Object r5 = r8.L$0 kotlinx.coroutines.channels.ProducerScope r5 = (kotlinx.coroutines.channels.ProducerScope) r5 kotlin.ResultKt.throwOnFailure(r9) goto L5b L3d: kotlin.ResultKt.throwOnFailure(r9) java.lang.Object r9 = r8.L$0 kotlinx.coroutines.channels.ProducerScope r9 = (kotlinx.coroutines.channels.ProducerScope) r9 kotlinx.coroutines.channels.ReceiveChannel r1 = r8.$this_flatMap kotlinx.coroutines.channels.ChannelIterator r1 = r1.iterator() r5 = r9 L4b: r9 = r8 kotlin.coroutines.Continuation r9 = (kotlin.coroutines.Continuation) r9 r8.L$0 = r5 r8.L$1 = r1 r8.label = r4 java.lang.Object r9 = r1.hasNext(r9) if (r9 != r0) goto L5b return r0 L5b: java.lang.Boolean r9 = (java.lang.Boolean) r9 boolean r9 = r9.booleanValue() if (r9 == 0) goto L8b java.lang.Object r9 = r1.next() kotlin.jvm.functions.Function2>, java.lang.Object> r6 = r8.$transform r8.L$0 = r5 r8.L$1 = r1 r8.label = r3 java.lang.Object r9 = r6.invoke(r9, r8) if (r9 != r0) goto L76 return r0 L76: kotlinx.coroutines.channels.ReceiveChannel r9 = (kotlinx.coroutines.channels.ReceiveChannel) r9 r6 = r5 kotlinx.coroutines.channels.SendChannel r6 = (kotlinx.coroutines.channels.SendChannel) r6 r7 = r8 kotlin.coroutines.Continuation r7 = (kotlin.coroutines.Continuation) r7 r8.L$0 = r5 r8.L$1 = r1 r8.label = r2 java.lang.Object r9 = kotlinx.coroutines.channels.ChannelsKt.toChannel(r9, r6, r7) if (r9 != r0) goto L4b return r0 L8b: kotlin.Unit r8 = kotlin.Unit.INSTANCE return r8 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00981.invokeSuspend(java.lang.Object):java.lang.Object"); } } @Deprecated(level = DeprecationLevel.HIDDEN, message = "Binary compatibility") public static final /* synthetic */ ReceiveChannel flatMap(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2 function2) { return ProduceKt.produce$default(GlobalScope.INSTANCE, coroutineContext, 0, null, ChannelsKt.consumes(receiveChannel), new C00981(receiveChannel, function2, null), 6, null); } public static /* synthetic */ ReceiveChannel map$default(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2 function2, int i, Object obj) { if ((i & 1) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return ChannelsKt.map(receiveChannel, coroutineContext, function2); } /* JADX INFO: Add missing generic type declarations: [R] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$map$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.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 = {"", "", "E", "R", "Lkotlinx/coroutines/channels/ProducerScope;"}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$map$1", f = "Deprecated.kt", i = {0, 0, 1, 1, 2, 2}, l = {487, 333, 333}, m = "invokeSuspend", n = {"$this$produce", "$this$consume$iv$iv", "$this$produce", "$this$consume$iv$iv", "$this$produce", "$this$consume$iv$iv"}, s = {"L$0", "L$2", "L$0", "L$2", "L$0", "L$2"}) static final class C01031 extends SuspendLambda implements Function2, Continuation, Object> { final /* synthetic */ ReceiveChannel $this_map; final /* synthetic */ Function2, Object> $transform; private /* synthetic */ Object L$0; Object L$1; Object L$2; Object L$3; Object L$4; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ /* JADX WARN: Multi-variable type inference failed */ C01031(ReceiveChannel receiveChannel, Function2, ? extends Object> function2, Continuation continuation) { super(2, continuation); this.$this_map = receiveChannel; this.$transform = function2; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C01031 c01031 = new C01031(this.$this_map, this.$transform, continuation); c01031.L$0 = obj; return c01031; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(ProducerScope producerScope, Continuation continuation) { return ((C01031) create(producerScope, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX WARN: Removed duplicated region for block: B:28:0x0093 A[Catch: all -> 0x00d1, TRY_LEAVE, TryCatch #0 {all -> 0x00d1, blocks: (B:8:0x0022, B:22:0x0076, B:26:0x008b, B:28:0x0093, B:36:0x00c9, B:18:0x005e, B:21:0x006e), top: B:44:0x000a }] */ /* JADX WARN: Removed duplicated region for block: B:34:0x00c2 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:35:0x00c3 */ /* JADX WARN: Removed duplicated region for block: B:36:0x00c9 A[Catch: all -> 0x00d1, TRY_ENTER, TRY_LEAVE, TryCatch #0 {all -> 0x00d1, blocks: (B:8:0x0022, B:22:0x0076, B:26:0x008b, B:28:0x0093, B:36:0x00c9, B:18:0x005e, B:21:0x006e), top: B:44:0x000a }] */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:35:0x00c3 -> B:22:0x0076). Please report as a decompilation issue!!! */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final java.lang.Object invokeSuspend(java.lang.Object r13) throws java.lang.Throwable { /* Method dump skipped, instruction units count: 216 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01031.invokeSuspend(java.lang.Object):java.lang.Object"); } } public static final ReceiveChannel map(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2, ? extends Object> function2) { return ProduceKt.produce$default(GlobalScope.INSTANCE, coroutineContext, 0, null, ChannelsKt.consumes(receiveChannel), new C01031(receiveChannel, function2, null), 6, null); } public static /* synthetic */ ReceiveChannel mapIndexed$default(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function3 function3, int i, Object obj) { if ((i & 1) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return ChannelsKt.mapIndexed(receiveChannel, coroutineContext, function3); } /* JADX INFO: Add missing generic type declarations: [R] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$mapIndexed$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.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 = {"", "", "E", "R", "Lkotlinx/coroutines/channels/ProducerScope;"}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$mapIndexed$1", f = "Deprecated.kt", i = {0, 0, 1, 1, 2, 2}, l = {344, 345, 345}, m = "invokeSuspend", n = {"$this$produce", "index", "$this$produce", "index", "$this$produce", "index"}, s = {"L$0", "I$0", "L$0", "I$0", "L$0", "I$0"}) static final class C01041 extends SuspendLambda implements Function2, Continuation, Object> { final /* synthetic */ ReceiveChannel $this_mapIndexed; final /* synthetic */ Function3, Object> $transform; int I$0; private /* synthetic */ Object L$0; Object L$1; Object L$2; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ /* JADX WARN: Multi-variable type inference failed */ C01041(ReceiveChannel receiveChannel, Function3, ? extends Object> function3, Continuation continuation) { super(2, continuation); this.$this_mapIndexed = receiveChannel; this.$transform = function3; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C01041 c01041 = new C01041(this.$this_mapIndexed, this.$transform, continuation); c01041.L$0 = obj; return c01041; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(ProducerScope producerScope, Continuation continuation) { return ((C01041) create(producerScope, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX WARN: Type inference incomplete: some casts might be missing */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:26:0x00ac -> B:13:0x0059). Please report as a decompilation issue!!! */ /* JADX ERROR: JadxRuntimeException in pass: ModVisitor jadx.core.utils.exceptions.JadxRuntimeException: Can't change immutable type java.lang.Object to kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$mapIndexed$1 for r11v3 'this' java.lang.Object at jadx.core.dex.instructions.args.SSAVar.setType(SSAVar.java:114) at jadx.core.dex.instructions.args.RegisterArg.setType(RegisterArg.java:52) at jadx.core.dex.visitors.ModVisitor.removeCheckCast(ModVisitor.java:417) at jadx.core.dex.visitors.ModVisitor.replaceStep(ModVisitor.java:152) at jadx.core.dex.visitors.ModVisitor.visit(ModVisitor.java:96) */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final java.lang.Object invokeSuspend(java.lang.Object r12) { /* r11 = this; java.lang.Object r0 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r1 = r11.label r2 = 3 r3 = 2 r4 = 1 if (r1 == 0) goto L48 if (r1 == r4) goto L3a if (r1 == r3) goto L28 if (r1 != r2) goto L20 int r1 = r11.I$0 java.lang.Object r5 = r11.L$1 kotlinx.coroutines.channels.ChannelIterator r5 = (kotlinx.coroutines.channels.ChannelIterator) r5 java.lang.Object r6 = r11.L$0 kotlinx.coroutines.channels.ProducerScope r6 = (kotlinx.coroutines.channels.ProducerScope) r6 kotlin.ResultKt.throwOnFailure(r12) r12 = r6 goto L59 L20: java.lang.IllegalStateException r11 = new java.lang.IllegalStateException java.lang.String r12 = "call to 'resume' before 'invoke' with coroutine" r11.(r12) throw r11 L28: int r1 = r11.I$0 java.lang.Object r5 = r11.L$2 kotlinx.coroutines.channels.ProducerScope r5 = (kotlinx.coroutines.channels.ProducerScope) r5 java.lang.Object r6 = r11.L$1 kotlinx.coroutines.channels.ChannelIterator r6 = (kotlinx.coroutines.channels.ChannelIterator) r6 java.lang.Object r7 = r11.L$0 kotlinx.coroutines.channels.ProducerScope r7 = (kotlinx.coroutines.channels.ProducerScope) r7 kotlin.ResultKt.throwOnFailure(r12) goto L97 L3a: int r1 = r11.I$0 java.lang.Object r5 = r11.L$1 kotlinx.coroutines.channels.ChannelIterator r5 = (kotlinx.coroutines.channels.ChannelIterator) r5 java.lang.Object r6 = r11.L$0 kotlinx.coroutines.channels.ProducerScope r6 = (kotlinx.coroutines.channels.ProducerScope) r6 kotlin.ResultKt.throwOnFailure(r12) goto L6e L48: kotlin.ResultKt.throwOnFailure(r12) java.lang.Object r12 = r11.L$0 kotlinx.coroutines.channels.ProducerScope r12 = (kotlinx.coroutines.channels.ProducerScope) r12 kotlinx.coroutines.channels.ReceiveChannel r1 = r11.$this_mapIndexed kotlinx.coroutines.channels.ChannelIterator r1 = r1.iterator() r5 = 0 r10 = r5 r5 = r1 r1 = r10 L59: r6 = r11 kotlin.coroutines.Continuation r6 = (kotlin.coroutines.Continuation) r6 r11.L$0 = r12 r11.L$1 = r5 r11.I$0 = r1 r11.label = r4 java.lang.Object r6 = r5.hasNext(r6) if (r6 != r0) goto L6b return r0 L6b: r10 = r6 r6 = r12 r12 = r10 L6e: java.lang.Boolean r12 = (java.lang.Boolean) r12 boolean r12 = r12.booleanValue() if (r12 == 0) goto Laf java.lang.Object r12 = r5.next() kotlin.jvm.functions.Function3, java.lang.Object> r7 = r11.$transform int r8 = r1 + 1 java.lang.Integer r1 = kotlin.coroutines.jvm.internal.Boxing.boxInt(r1) r11.L$0 = r6 r11.L$1 = r5 r11.L$2 = r6 r11.I$0 = r8 r11.label = r3 java.lang.Object r12 = r7.invoke(r1, r12, r11) if (r12 != r0) goto L93 return r0 L93: r7 = r6 r1 = r8 r6 = r5 r5 = r7 L97: r8 = r11 kotlin.coroutines.Continuation r8 = (kotlin.coroutines.Continuation) r8 r11.L$0 = r7 r11.L$1 = r6 r9 = 0 r11.L$2 = r9 r11.I$0 = r1 r11.label = r2 java.lang.Object r12 = r5.send(r12, r8) if (r12 != r0) goto Lac return r0 Lac: r5 = r6 r12 = r7 goto L59 Laf: kotlin.Unit r11 = kotlin.Unit.INSTANCE return r11 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01041.invokeSuspend(java.lang.Object):java.lang.Object"); } } public static final ReceiveChannel mapIndexed(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function3, ? extends Object> function3) { return ProduceKt.produce$default(GlobalScope.INSTANCE, coroutineContext, 0, null, ChannelsKt.consumes(receiveChannel), new C01041(receiveChannel, function3, null), 6, null); } public static /* synthetic */ ReceiveChannel mapIndexedNotNull$default(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function3 function3, int i, Object obj) { if ((i & 1) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return mapIndexedNotNull(receiveChannel, coroutineContext, function3); } @Deprecated(level = DeprecationLevel.HIDDEN, message = "Binary compatibility") public static final /* synthetic */ ReceiveChannel mapIndexedNotNull(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function3 function3) { return ChannelsKt.filterNotNull(ChannelsKt.mapIndexed(receiveChannel, coroutineContext, function3)); } public static /* synthetic */ ReceiveChannel mapNotNull$default(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2 function2, int i, Object obj) { if ((i & 1) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return mapNotNull(receiveChannel, coroutineContext, function2); } @Deprecated(level = DeprecationLevel.HIDDEN, message = "Binary compatibility") public static final /* synthetic */ ReceiveChannel mapNotNull(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2 function2) { return ChannelsKt.filterNotNull(ChannelsKt.map(receiveChannel, coroutineContext, function2)); } /* JADX INFO: Add missing generic type declarations: [E] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$withIndex$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(d1 = {"\u0000\u0010\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\u0010\u0000\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u0002*\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u0002H\u00020\u00040\u0003H\u008a@"}, d2 = {"", "", "E", "Lkotlinx/coroutines/channels/ProducerScope;", "Lkotlin/collections/IndexedValue;"}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$withIndex$1", f = "Deprecated.kt", i = {0, 0, 1, 1}, l = {370, 371}, m = "invokeSuspend", n = {"$this$produce", "index", "$this$produce", "index"}, s = {"L$0", "I$0", "L$0", "I$0"}) static final class C01151 extends SuspendLambda implements Function2>, Continuation, Object> { final /* synthetic */ ReceiveChannel $this_withIndex; int I$0; private /* synthetic */ Object L$0; Object L$1; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ /* JADX WARN: Multi-variable type inference failed */ C01151(ReceiveChannel receiveChannel, Continuation continuation) { super(2, continuation); this.$this_withIndex = receiveChannel; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C01151 c01151 = new C01151(this.$this_withIndex, continuation); c01151.L$0 = obj; return c01151; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(ProducerScope> producerScope, Continuation continuation) { return ((C01151) create(producerScope, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX WARN: Removed duplicated region for block: B:17:0x0064 */ /* JADX WARN: Removed duplicated region for block: B:21:0x0085 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:20:0x0081 -> B:11:0x0044). Please report as a decompilation issue!!! */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final java.lang.Object invokeSuspend(java.lang.Object r11) throws java.lang.Throwable { /* r10 = this; java.lang.Object r0 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r1 = r10.label r2 = 2 r3 = 1 if (r1 == 0) goto L36 if (r1 == r3) goto L28 if (r1 != r2) goto L20 int r1 = r10.I$0 java.lang.Object r4 = r10.L$1 kotlinx.coroutines.channels.ChannelIterator r4 = (kotlinx.coroutines.channels.ChannelIterator) r4 java.lang.Object r5 = r10.L$0 kotlinx.coroutines.channels.ProducerScope r5 = (kotlinx.coroutines.channels.ProducerScope) r5 kotlin.ResultKt.throwOnFailure(r11) r11 = r5 r8 = r4 r4 = r1 r1 = r8 goto L44 L20: java.lang.IllegalStateException r10 = new java.lang.IllegalStateException java.lang.String r11 = "call to 'resume' before 'invoke' with coroutine" r10.(r11) throw r10 L28: int r1 = r10.I$0 java.lang.Object r4 = r10.L$1 kotlinx.coroutines.channels.ChannelIterator r4 = (kotlinx.coroutines.channels.ChannelIterator) r4 java.lang.Object r5 = r10.L$0 kotlinx.coroutines.channels.ProducerScope r5 = (kotlinx.coroutines.channels.ProducerScope) r5 kotlin.ResultKt.throwOnFailure(r11) goto L5c L36: kotlin.ResultKt.throwOnFailure(r11) java.lang.Object r11 = r10.L$0 kotlinx.coroutines.channels.ProducerScope r11 = (kotlinx.coroutines.channels.ProducerScope) r11 kotlinx.coroutines.channels.ReceiveChannel r1 = r10.$this_withIndex kotlinx.coroutines.channels.ChannelIterator r1 = r1.iterator() r4 = 0 L44: r5 = r10 kotlin.coroutines.Continuation r5 = (kotlin.coroutines.Continuation) r5 r10.L$0 = r11 r10.L$1 = r1 r10.I$0 = r4 r10.label = r3 java.lang.Object r5 = r1.hasNext(r5) if (r5 != r0) goto L56 return r0 L56: r8 = r5 r5 = r11 r11 = r8 r9 = r4 r4 = r1 r1 = r9 L5c: java.lang.Boolean r11 = (java.lang.Boolean) r11 boolean r11 = r11.booleanValue() if (r11 == 0) goto L85 java.lang.Object r11 = r4.next() kotlin.collections.IndexedValue r6 = new kotlin.collections.IndexedValue int r7 = r1 + 1 r6.(r1, r11) r11 = r10 kotlin.coroutines.Continuation r11 = (kotlin.coroutines.Continuation) r11 r10.L$0 = r5 r10.L$1 = r4 r10.I$0 = r7 r10.label = r2 java.lang.Object r11 = r5.send(r6, r11) if (r11 != r0) goto L81 return r0 L81: r1 = r4 r11 = r5 r4 = r7 goto L44 L85: kotlin.Unit r10 = kotlin.Unit.INSTANCE return r10 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01151.invokeSuspend(java.lang.Object):java.lang.Object"); } } public static /* synthetic */ ReceiveChannel withIndex$default(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, int i, Object obj) { if ((i & 1) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return withIndex(receiveChannel, coroutineContext); } @Deprecated(level = DeprecationLevel.HIDDEN, message = "Binary compatibility") public static final /* synthetic */ ReceiveChannel withIndex(ReceiveChannel receiveChannel, CoroutineContext coroutineContext) { return ProduceKt.produce$default(GlobalScope.INSTANCE, coroutineContext, 0, null, ChannelsKt.consumes(receiveChannel), new C01151(receiveChannel, null), 6, null); } /* JADX INFO: Add missing generic type declarations: [E] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$distinct$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(d1 = {"\u0000\u0004\n\u0002\b\u0003\u0010\u0000\u001a\u0002H\u0001\"\u0004\b\u0000\u0010\u00012\u0006\u0010\u0002\u001a\u0002H\u0001H\u008a@"}, d2 = {"", "E", LanguageUtils.ITALIAN_NAME}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$distinct$1", f = "Deprecated.kt", i = {}, l = {}, m = "invokeSuspend", n = {}, s = {}) static final class C00851 extends SuspendLambda implements Function2, Object> { /* synthetic */ Object L$0; int label; C00851(Continuation continuation) { super(2, continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C00851 c00851 = new C00851(continuation); c00851.L$0 = obj; return c00851; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(E e, Continuation continuation) { return ((C00851) create(e, continuation)).invokeSuspend(Unit.INSTANCE); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) throws Throwable { IntrinsicsKt.getCOROUTINE_SUSPENDED(); if (this.label != 0) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } ResultKt.throwOnFailure(obj); return this.L$0; } } public static /* synthetic */ ReceiveChannel distinctBy$default(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2 function2, int i, Object obj) { if ((i & 1) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return ChannelsKt.distinctBy(receiveChannel, coroutineContext, function2); } /* JADX INFO: Add missing generic type declarations: [E] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$distinctBy$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.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\u00020\u0004H\u008a@"}, d2 = {"", "", "E", "K", "Lkotlinx/coroutines/channels/ProducerScope;"}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$distinctBy$1", f = "Deprecated.kt", i = {0, 0, 1, 1, 1, 2, 2, 2}, l = {387, 388, 390}, m = "invokeSuspend", n = {"$this$produce", "keys", "$this$produce", "keys", "e", "$this$produce", "keys", "k"}, s = {"L$0", "L$1", "L$0", "L$1", "L$3", "L$0", "L$1", "L$3"}) static final class C00861 extends SuspendLambda implements Function2, Continuation, Object> { final /* synthetic */ Function2, Object> $selector; final /* synthetic */ ReceiveChannel $this_distinctBy; private /* synthetic */ Object L$0; Object L$1; Object L$2; Object L$3; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ /* JADX WARN: Multi-variable type inference failed */ C00861(ReceiveChannel receiveChannel, Function2, ? extends Object> function2, Continuation continuation) { super(2, continuation); this.$this_distinctBy = receiveChannel; this.$selector = function2; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C00861 c00861 = new C00861(this.$this_distinctBy, this.$selector, continuation); c00861.L$0 = obj; return c00861; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(ProducerScope producerScope, Continuation continuation) { return ((C00861) create(producerScope, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Type inference failed for: r11v13, types: [java.util.Collection] */ /* JADX WARN: Type inference failed for: r6v0 */ /* JADX WARN: Type inference failed for: r6v14 */ /* JADX WARN: Type inference failed for: r6v15 */ /* JADX WARN: Type inference failed for: r6v2, types: [java.lang.Object] */ /* JADX WARN: Type inference failed for: r6v4, types: [java.lang.Object] */ /* JADX WARN: Type inference failed for: r6v6 */ /* JADX WARN: Type inference failed for: r7v0, types: [java.lang.Object, kotlinx.coroutines.channels.ProducerScope] */ /* JADX WARN: Type inference failed for: r7v11 */ /* JADX WARN: Type inference failed for: r7v12 */ /* JADX WARN: Type inference failed for: r7v13 */ /* JADX WARN: Type inference failed for: r7v14 */ /* JADX WARN: Type inference failed for: r7v15 */ /* JADX WARN: Type inference failed for: r7v3 */ /* JADX WARN: Type inference failed for: r7v5 */ /* JADX WARN: Type inference failed for: r7v6 */ /* JADX WARN: Type inference incomplete: some casts might be missing */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:23:0x00a4 -> B:29:0x00c3). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:27:0x00ba -> B:28:0x00bc). Please report as a decompilation issue!!! */ /* JADX ERROR: JadxRuntimeException in pass: ModVisitor jadx.core.utils.exceptions.JadxRuntimeException: Can't change immutable type java.lang.Object to kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$distinctBy$1 for r10v3 'this' java.lang.Object at jadx.core.dex.instructions.args.SSAVar.setType(SSAVar.java:114) at jadx.core.dex.instructions.args.RegisterArg.setType(RegisterArg.java:52) at jadx.core.dex.visitors.ModVisitor.removeCheckCast(ModVisitor.java:417) at jadx.core.dex.visitors.ModVisitor.replaceStep(ModVisitor.java:152) at jadx.core.dex.visitors.ModVisitor.visit(ModVisitor.java:96) */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final java.lang.Object invokeSuspend(java.lang.Object r11) { /* Method dump skipped, instruction units count: 201 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00861.invokeSuspend(java.lang.Object):java.lang.Object"); } } public static final ReceiveChannel distinctBy(ReceiveChannel receiveChannel, CoroutineContext coroutineContext, Function2, ? extends Object> function2) { return ProduceKt.produce$default(GlobalScope.INSTANCE, coroutineContext, 0, null, ChannelsKt.consumes(receiveChannel), new C00861(receiveChannel, function2, null), 6, null); } public static final Object toMutableSet(ReceiveChannel receiveChannel, Continuation> continuation) { return ChannelsKt.toCollection(receiveChannel, new LinkedHashSet(), continuation); } /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object any(kotlinx.coroutines.channels.ReceiveChannel r4, kotlin.coroutines.Continuation r5) throws java.lang.Throwable { /* boolean r0 = r5 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.AnonymousClass1 if (r0 == 0) goto L14 r0 = r5 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$any$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.AnonymousClass1) r0 int r1 = r0.label r2 = -2147483648(0xffffffff80000000, float:-0.0) r1 = r1 & r2 if (r1 == 0) goto L14 int r5 = r0.label int r5 = r5 - r2 r0.label = r5 goto L19 L14: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$any$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$any$1 r0.(r5) L19: java.lang.Object r5 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 1 if (r2 == 0) goto L36 if (r2 != r3) goto L2e java.lang.Object r4 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r4 = (kotlinx.coroutines.channels.ReceiveChannel) r4 kotlin.ResultKt.throwOnFailure(r5) // Catch: java.lang.Throwable -> L4d goto L48 L2e: java.lang.IllegalStateException r4 = new java.lang.IllegalStateException java.lang.String r5 = "call to 'resume' before 'invoke' with coroutine" r4.(r5) throw r4 L36: kotlin.ResultKt.throwOnFailure(r5) kotlinx.coroutines.channels.ChannelIterator r5 = r4.iterator() // Catch: java.lang.Throwable -> L4d r0.L$0 = r4 // Catch: java.lang.Throwable -> L4d r0.label = r3 // Catch: java.lang.Throwable -> L4d java.lang.Object r5 = r5.hasNext(r0) // Catch: java.lang.Throwable -> L4d if (r5 != r1) goto L48 return r1 L48: r0 = 0 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r4, r0) return r5 L4d: r5 = move-exception throw r5 // Catch: java.lang.Throwable -> L4f L4f: r0 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r4, r5) throw r0 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.any(kotlinx.coroutines.channels.ReceiveChannel, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:23:0x005e A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:24:0x005f */ /* JADX WARN: Removed duplicated region for block: B:27:0x006a A[Catch: all -> 0x0037, TryCatch #3 {all -> 0x0037, blocks: (B:12:0x0033, B:25:0x0062, B:27:0x006a, B:28:0x0074), top: B:45:0x0033 }] */ /* JADX WARN: Removed duplicated region for block: B:28:0x0074 A[Catch: all -> 0x0037, TRY_LEAVE, TryCatch #3 {all -> 0x0037, blocks: (B:12:0x0033, B:25:0x0062, B:27:0x006a, B:28:0x0074), top: B:45:0x0033 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:24:0x005f -> B:25:0x0062). Please report as a decompilation issue!!! */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object count(kotlinx.coroutines.channels.ReceiveChannel r7, kotlin.coroutines.Continuation r8) throws java.lang.Throwable { /* boolean r0 = r8 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00841 if (r0 == 0) goto L14 r0 = r8 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$count$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C00841) 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.channels.ChannelsKt__DeprecatedKt$count$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$count$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 = 0 r4 = 1 if (r2 == 0) goto L41 if (r2 != r4) goto L39 java.lang.Object r7 = r0.L$2 kotlinx.coroutines.channels.ChannelIterator r7 = (kotlinx.coroutines.channels.ChannelIterator) r7 java.lang.Object r2 = r0.L$1 kotlinx.coroutines.channels.ReceiveChannel r2 = (kotlinx.coroutines.channels.ReceiveChannel) r2 java.lang.Object r5 = r0.L$0 kotlin.jvm.internal.Ref$IntRef r5 = (kotlin.jvm.internal.Ref.IntRef) r5 kotlin.ResultKt.throwOnFailure(r8) // Catch: java.lang.Throwable -> L37 goto L62 L37: r7 = move-exception goto L86 L39: java.lang.IllegalStateException r7 = new java.lang.IllegalStateException java.lang.String r8 = "call to 'resume' before 'invoke' with coroutine" r7.(r8) throw r7 L41: kotlin.ResultKt.throwOnFailure(r8) kotlin.jvm.internal.Ref$IntRef r8 = new kotlin.jvm.internal.Ref$IntRef r8.() kotlinx.coroutines.channels.ChannelIterator r2 = r7.iterator() // Catch: java.lang.Throwable -> L83 r5 = r8 r8 = r7 r7 = r2 L50: r0.L$0 = r5 // Catch: java.lang.Throwable -> L80 r0.L$1 = r8 // Catch: java.lang.Throwable -> L80 r0.L$2 = r7 // Catch: java.lang.Throwable -> L80 r0.label = r4 // Catch: java.lang.Throwable -> L80 java.lang.Object r2 = r7.hasNext(r0) // Catch: java.lang.Throwable -> L80 if (r2 != r1) goto L5f return r1 L5f: r6 = r2 r2 = r8 r8 = r6 L62: java.lang.Boolean r8 = (java.lang.Boolean) r8 // Catch: java.lang.Throwable -> L37 boolean r8 = r8.booleanValue() // Catch: java.lang.Throwable -> L37 if (r8 == 0) goto L74 r7.next() // Catch: java.lang.Throwable -> L37 int r8 = r5.element // Catch: java.lang.Throwable -> L37 int r8 = r8 + r4 r5.element = r8 // Catch: java.lang.Throwable -> L37 r8 = r2 goto L50 L74: kotlin.Unit r7 = kotlin.Unit.INSTANCE // Catch: java.lang.Throwable -> L37 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r2, r3) int r7 = r5.element java.lang.Integer r7 = kotlin.coroutines.jvm.internal.Boxing.boxInt(r7) return r7 L80: r7 = move-exception r2 = r8 goto L86 L83: r8 = move-exception r2 = r7 r7 = r8 L86: throw r7 // Catch: java.lang.Throwable -> L87 L87: r8 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r2, r7) throw r8 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.count(kotlinx.coroutines.channels.ReceiveChannel, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:38:0x009f A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:39:0x00a0 */ /* JADX WARN: Removed duplicated region for block: B:42:0x00ac A[Catch: all -> 0x00be, TRY_LEAVE, TryCatch #3 {all -> 0x00be, blocks: (B:40:0x00a4, B:42:0x00ac, B:36:0x008f, B:26:0x0063), top: B:61:0x0063 }] */ /* JADX WARN: Removed duplicated region for block: B:47:0x00ba */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:39:0x00a0 -> B:15:0x003e). Please report as a decompilation issue!!! */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object maxWith(kotlinx.coroutines.channels.ReceiveChannel r8, java.util.Comparator r9, kotlin.coroutines.Continuation r10) throws java.lang.Throwable { /* boolean r0 = r10 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01051 if (r0 == 0) goto L14 r0 = r10 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$maxWith$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01051) r0 int r1 = r0.label r2 = -2147483648(0xffffffff80000000, float:-0.0) r1 = r1 & r2 if (r1 == 0) goto L14 int r10 = r0.label int r10 = r10 - r2 r0.label = r10 goto L19 L14: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$maxWith$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$maxWith$1 r0.(r10) L19: java.lang.Object r10 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 2 r4 = 1 r5 = 0 if (r2 == 0) goto L60 if (r2 == r4) goto L4d if (r2 != r3) goto L45 java.lang.Object r8 = r0.L$3 java.lang.Object r9 = r0.L$2 kotlinx.coroutines.channels.ChannelIterator r9 = (kotlinx.coroutines.channels.ChannelIterator) r9 java.lang.Object r2 = r0.L$1 kotlinx.coroutines.channels.ReceiveChannel r2 = (kotlinx.coroutines.channels.ReceiveChannel) r2 java.lang.Object r4 = r0.L$0 java.util.Comparator r4 = (java.util.Comparator) r4 kotlin.ResultKt.throwOnFailure(r10) // Catch: java.lang.Throwable -> L41 r7 = r0 r0 = r8 r8 = r2 L3e: r2 = r7 goto La4 L41: r8 = move-exception r9 = r2 goto Lc2 L45: java.lang.IllegalStateException r8 = new java.lang.IllegalStateException java.lang.String r9 = "call to 'resume' before 'invoke' with coroutine" r8.(r9) throw r8 L4d: java.lang.Object r8 = r0.L$2 kotlinx.coroutines.channels.ChannelIterator r8 = (kotlinx.coroutines.channels.ChannelIterator) r8 java.lang.Object r9 = r0.L$1 kotlinx.coroutines.channels.ReceiveChannel r9 = (kotlinx.coroutines.channels.ReceiveChannel) r9 java.lang.Object r2 = r0.L$0 java.util.Comparator r2 = (java.util.Comparator) r2 kotlin.ResultKt.throwOnFailure(r10) // Catch: java.lang.Throwable -> L5d goto L7b L5d: r8 = move-exception goto Lc2 L60: kotlin.ResultKt.throwOnFailure(r10) kotlinx.coroutines.channels.ChannelIterator r10 = r8.iterator() // Catch: java.lang.Throwable -> Lbe r0.L$0 = r9 // Catch: java.lang.Throwable -> Lbe r0.L$1 = r8 // Catch: java.lang.Throwable -> Lbe r0.L$2 = r10 // Catch: java.lang.Throwable -> Lbe r0.label = r4 // Catch: java.lang.Throwable -> Lbe java.lang.Object r2 = r10.hasNext(r0) // Catch: java.lang.Throwable -> Lbe if (r2 != r1) goto L76 return r1 L76: r7 = r9 r9 = r8 r8 = r10 r10 = r2 r2 = r7 L7b: java.lang.Boolean r10 = (java.lang.Boolean) r10 // Catch: java.lang.Throwable -> L5d boolean r10 = r10.booleanValue() // Catch: java.lang.Throwable -> L5d if (r10 != 0) goto L87 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r9, r5) return r5 L87: java.lang.Object r10 = r8.next() // Catch: java.lang.Throwable -> L5d r4 = r2 r7 = r9 r9 = r8 r8 = r7 L8f: r0.L$0 = r4 // Catch: java.lang.Throwable -> Lbe r0.L$1 = r8 // Catch: java.lang.Throwable -> Lbe r0.L$2 = r9 // Catch: java.lang.Throwable -> Lbe r0.L$3 = r10 // Catch: java.lang.Throwable -> Lbe r0.label = r3 // Catch: java.lang.Throwable -> Lbe java.lang.Object r2 = r9.hasNext(r0) // Catch: java.lang.Throwable -> Lbe if (r2 != r1) goto La0 return r1 La0: r7 = r0 r0 = r10 r10 = r2 goto L3e La4: java.lang.Boolean r10 = (java.lang.Boolean) r10 // Catch: java.lang.Throwable -> Lbe boolean r10 = r10.booleanValue() // Catch: java.lang.Throwable -> Lbe if (r10 == 0) goto Lba java.lang.Object r10 = r9.next() // Catch: java.lang.Throwable -> Lbe int r6 = r4.compare(r0, r10) // Catch: java.lang.Throwable -> Lbe if (r6 >= 0) goto Lb7 goto Lb8 Lb7: r10 = r0 Lb8: r0 = r2 goto L8f Lba: kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r8, r5) return r0 Lbe: r9 = move-exception r7 = r9 r9 = r8 r8 = r7 Lc2: throw r8 // Catch: java.lang.Throwable -> Lc3 Lc3: r10 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r9, r8) throw r10 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.maxWith(kotlinx.coroutines.channels.ReceiveChannel, java.util.Comparator, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:38:0x009f A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:39:0x00a0 */ /* JADX WARN: Removed duplicated region for block: B:42:0x00ac A[Catch: all -> 0x00be, TRY_LEAVE, TryCatch #3 {all -> 0x00be, blocks: (B:40:0x00a4, B:42:0x00ac, B:36:0x008f, B:26:0x0063), top: B:61:0x0063 }] */ /* JADX WARN: Removed duplicated region for block: B:47:0x00ba */ /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:39:0x00a0 -> B:15:0x003e). Please report as a decompilation issue!!! */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object minWith(kotlinx.coroutines.channels.ReceiveChannel r8, java.util.Comparator r9, kotlin.coroutines.Continuation r10) throws java.lang.Throwable { /* boolean r0 = r10 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01061 if (r0 == 0) goto L14 r0 = r10 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$minWith$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01061) r0 int r1 = r0.label r2 = -2147483648(0xffffffff80000000, float:-0.0) r1 = r1 & r2 if (r1 == 0) goto L14 int r10 = r0.label int r10 = r10 - r2 r0.label = r10 goto L19 L14: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$minWith$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$minWith$1 r0.(r10) L19: java.lang.Object r10 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 2 r4 = 1 r5 = 0 if (r2 == 0) goto L60 if (r2 == r4) goto L4d if (r2 != r3) goto L45 java.lang.Object r8 = r0.L$3 java.lang.Object r9 = r0.L$2 kotlinx.coroutines.channels.ChannelIterator r9 = (kotlinx.coroutines.channels.ChannelIterator) r9 java.lang.Object r2 = r0.L$1 kotlinx.coroutines.channels.ReceiveChannel r2 = (kotlinx.coroutines.channels.ReceiveChannel) r2 java.lang.Object r4 = r0.L$0 java.util.Comparator r4 = (java.util.Comparator) r4 kotlin.ResultKt.throwOnFailure(r10) // Catch: java.lang.Throwable -> L41 r7 = r0 r0 = r8 r8 = r2 L3e: r2 = r7 goto La4 L41: r8 = move-exception r9 = r2 goto Lc2 L45: java.lang.IllegalStateException r8 = new java.lang.IllegalStateException java.lang.String r9 = "call to 'resume' before 'invoke' with coroutine" r8.(r9) throw r8 L4d: java.lang.Object r8 = r0.L$2 kotlinx.coroutines.channels.ChannelIterator r8 = (kotlinx.coroutines.channels.ChannelIterator) r8 java.lang.Object r9 = r0.L$1 kotlinx.coroutines.channels.ReceiveChannel r9 = (kotlinx.coroutines.channels.ReceiveChannel) r9 java.lang.Object r2 = r0.L$0 java.util.Comparator r2 = (java.util.Comparator) r2 kotlin.ResultKt.throwOnFailure(r10) // Catch: java.lang.Throwable -> L5d goto L7b L5d: r8 = move-exception goto Lc2 L60: kotlin.ResultKt.throwOnFailure(r10) kotlinx.coroutines.channels.ChannelIterator r10 = r8.iterator() // Catch: java.lang.Throwable -> Lbe r0.L$0 = r9 // Catch: java.lang.Throwable -> Lbe r0.L$1 = r8 // Catch: java.lang.Throwable -> Lbe r0.L$2 = r10 // Catch: java.lang.Throwable -> Lbe r0.label = r4 // Catch: java.lang.Throwable -> Lbe java.lang.Object r2 = r10.hasNext(r0) // Catch: java.lang.Throwable -> Lbe if (r2 != r1) goto L76 return r1 L76: r7 = r9 r9 = r8 r8 = r10 r10 = r2 r2 = r7 L7b: java.lang.Boolean r10 = (java.lang.Boolean) r10 // Catch: java.lang.Throwable -> L5d boolean r10 = r10.booleanValue() // Catch: java.lang.Throwable -> L5d if (r10 != 0) goto L87 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r9, r5) return r5 L87: java.lang.Object r10 = r8.next() // Catch: java.lang.Throwable -> L5d r4 = r2 r7 = r9 r9 = r8 r8 = r7 L8f: r0.L$0 = r4 // Catch: java.lang.Throwable -> Lbe r0.L$1 = r8 // Catch: java.lang.Throwable -> Lbe r0.L$2 = r9 // Catch: java.lang.Throwable -> Lbe r0.L$3 = r10 // Catch: java.lang.Throwable -> Lbe r0.label = r3 // Catch: java.lang.Throwable -> Lbe java.lang.Object r2 = r9.hasNext(r0) // Catch: java.lang.Throwable -> Lbe if (r2 != r1) goto La0 return r1 La0: r7 = r0 r0 = r10 r10 = r2 goto L3e La4: java.lang.Boolean r10 = (java.lang.Boolean) r10 // Catch: java.lang.Throwable -> Lbe boolean r10 = r10.booleanValue() // Catch: java.lang.Throwable -> Lbe if (r10 == 0) goto Lba java.lang.Object r10 = r9.next() // Catch: java.lang.Throwable -> Lbe int r6 = r4.compare(r0, r10) // Catch: java.lang.Throwable -> Lbe if (r6 <= 0) goto Lb7 goto Lb8 Lb7: r10 = r0 Lb8: r0 = r2 goto L8f Lba: kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r8, r5) return r0 Lbe: r9 = move-exception r7 = r9 r9 = r8 r8 = r7 Lc2: throw r8 // Catch: java.lang.Throwable -> Lc3 Lc3: r10 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r9, r8) throw r10 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.minWith(kotlinx.coroutines.channels.ReceiveChannel, java.util.Comparator, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:7:0x0014 */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.HIDDEN, message = "Binary compatibility") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final /* synthetic */ java.lang.Object none(kotlinx.coroutines.channels.ReceiveChannel r4, kotlin.coroutines.Continuation r5) throws java.lang.Throwable { /* boolean r0 = r5 instanceof kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01071 if (r0 == 0) goto L14 r0 = r5 kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$none$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01071) r0 int r1 = r0.label r2 = -2147483648(0xffffffff80000000, float:-0.0) r1 = r1 & r2 if (r1 == 0) goto L14 int r5 = r0.label int r5 = r5 - r2 r0.label = r5 goto L19 L14: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$none$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$none$1 r0.(r5) L19: java.lang.Object r5 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 1 if (r2 == 0) goto L36 if (r2 != r3) goto L2e java.lang.Object r4 = r0.L$0 kotlinx.coroutines.channels.ReceiveChannel r4 = (kotlinx.coroutines.channels.ReceiveChannel) r4 kotlin.ResultKt.throwOnFailure(r5) // Catch: java.lang.Throwable -> L58 goto L48 L2e: java.lang.IllegalStateException r4 = new java.lang.IllegalStateException java.lang.String r5 = "call to 'resume' before 'invoke' with coroutine" r4.(r5) throw r4 L36: kotlin.ResultKt.throwOnFailure(r5) kotlinx.coroutines.channels.ChannelIterator r5 = r4.iterator() // Catch: java.lang.Throwable -> L58 r0.L$0 = r4 // Catch: java.lang.Throwable -> L58 r0.label = r3 // Catch: java.lang.Throwable -> L58 java.lang.Object r5 = r5.hasNext(r0) // Catch: java.lang.Throwable -> L58 if (r5 != r1) goto L48 return r1 L48: java.lang.Boolean r5 = (java.lang.Boolean) r5 // Catch: java.lang.Throwable -> L58 boolean r5 = r5.booleanValue() // Catch: java.lang.Throwable -> L58 r5 = r5 ^ r3 java.lang.Boolean r5 = kotlin.coroutines.jvm.internal.Boxing.boxBoolean(r5) // Catch: java.lang.Throwable -> L58 r0 = 0 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r4, r0) return r5 L58: r5 = move-exception throw r5 // Catch: java.lang.Throwable -> L5a L5a: r0 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r4, r5) throw r0 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.none(kotlinx.coroutines.channels.ReceiveChannel, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX INFO: Add missing generic type declarations: [E] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$requireNoNulls$1, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(d1 = {"\u0000\n\n\u0002\b\u0002\n\u0002\u0010\u0000\n\u0000\u0010\u0000\u001a\u0002H\u0001\"\b\b\u0000\u0010\u0001*\u00020\u00022\b\u0010\u0003\u001a\u0004\u0018\u0001H\u0001H\u008a@"}, d2 = {"", "E", "", LanguageUtils.ITALIAN_NAME}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$requireNoNulls$1", f = "Deprecated.kt", i = {}, l = {}, m = "invokeSuspend", n = {}, s = {}) static final class C01081 extends SuspendLambda implements Function2, Object> { final /* synthetic */ ReceiveChannel $this_requireNoNulls; /* 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 */ C01081(ReceiveChannel receiveChannel, Continuation continuation) { super(2, continuation); this.$this_requireNoNulls = receiveChannel; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C01081 c01081 = new C01081(this.$this_requireNoNulls, continuation); c01081.L$0 = obj; return c01081; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(E e, Continuation continuation) { return ((C01081) create(e, continuation)).invokeSuspend(Unit.INSTANCE); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) throws Throwable { IntrinsicsKt.getCOROUTINE_SUSPENDED(); if (this.label != 0) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } ResultKt.throwOnFailure(obj); Object obj2 = this.L$0; if (obj2 != null) { return obj2; } throw new IllegalArgumentException("null element found in " + this.$this_requireNoNulls + '.'); } } public static /* synthetic */ ReceiveChannel zip$default(ReceiveChannel receiveChannel, ReceiveChannel receiveChannel2, CoroutineContext coroutineContext, Function2 function2, int i, Object obj) { if ((i & 2) != 0) { coroutineContext = Dispatchers.getUnconfined(); } return ChannelsKt.zip(receiveChannel, receiveChannel2, coroutineContext, function2); } /* JADX INFO: Add missing generic type declarations: [V] */ /* JADX INFO: renamed from: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$zip$2, reason: invalid class name and case insensitive filesystem */ /* JADX INFO: compiled from: Deprecated.kt */ @Metadata(d1 = {"\u0000\u000e\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\u0010\u0000\u001a\u00020\u0001\"\u0004\b\u0000\u0010\u0002\"\u0004\b\u0001\u0010\u0003\"\u0004\b\u0002\u0010\u0004*\b\u0012\u0004\u0012\u0002H\u00040\u0005H\u008a@"}, d2 = {"", "", "E", "R", "V", "Lkotlinx/coroutines/channels/ProducerScope;"}, k = 3, mv = {1, 6, 0}, xi = 48) @DebugMetadata(c = "kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt$zip$2", f = "Deprecated.kt", i = {0, 0, 0, 1, 1, 1, 1, 2, 2, 2}, l = {487, 469, 471}, m = "invokeSuspend", n = {"$this$produce", "otherIterator", "$this$consume$iv$iv", "$this$produce", "otherIterator", "$this$consume$iv$iv", "element1", "$this$produce", "otherIterator", "$this$consume$iv$iv"}, s = {"L$0", "L$1", "L$3", "L$0", "L$1", "L$3", "L$5", "L$0", "L$1", "L$3"}) static final class C01172 extends SuspendLambda implements Function2, Continuation, Object> { final /* synthetic */ ReceiveChannel $other; final /* synthetic */ ReceiveChannel $this_zip; final /* synthetic */ Function2 $transform; private /* synthetic */ Object L$0; Object L$1; Object L$2; Object L$3; Object L$4; Object L$5; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ /* JADX WARN: Multi-variable type inference failed */ C01172(ReceiveChannel receiveChannel, ReceiveChannel receiveChannel2, Function2 function2, Continuation continuation) { super(2, continuation); this.$other = receiveChannel; this.$this_zip = receiveChannel2; this.$transform = function2; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C01172 c01172 = new C01172(this.$other, this.$this_zip, this.$transform, continuation); c01172.L$0 = obj; return c01172; } @Override // kotlin.jvm.functions.Function2 public final Object invoke(ProducerScope producerScope, Continuation continuation) { return ((C01172) create(producerScope, continuation)).invokeSuspend(Unit.INSTANCE); } /* JADX WARN: Code restructure failed: missing block: B:56:0x0091, code lost: r14 = r1; r1 = r6; r6 = r8; r7 = r9; r8 = r10; r9 = r11; */ /* JADX WARN: Removed duplicated region for block: B:28:0x00b6 A[Catch: all -> 0x0055, TRY_LEAVE, TryCatch #1 {all -> 0x0055, blocks: (B:26:0x00ae, B:28:0x00b6, B:40:0x0105, B:13:0x004a), top: B:50:0x004a }] */ /* JADX WARN: Removed duplicated region for block: B:34:0x00de A[Catch: all -> 0x0102, TRY_LEAVE, TryCatch #0 {all -> 0x0102, blocks: (B:32:0x00d6, B:34:0x00de), top: B:48:0x00d6 }] */ /* JADX WARN: Removed duplicated region for block: B:37:0x00fb */ /* JADX WARN: Removed duplicated region for block: B:40:0x0105 A[Catch: all -> 0x0055, TRY_ENTER, TRY_LEAVE, TryCatch #1 {all -> 0x0055, blocks: (B:26:0x00ae, B:28:0x00b6, B:40:0x0105, B:13:0x004a), top: B:50:0x004a }] */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public final java.lang.Object invokeSuspend(java.lang.Object r14) throws java.lang.Throwable { /* Method dump skipped, instruction units count: 276 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.C01172.invokeSuspend(java.lang.Object):java.lang.Object"); } } public static final ReceiveChannel zip(ReceiveChannel receiveChannel, ReceiveChannel receiveChannel2, CoroutineContext coroutineContext, Function2 function2) { return ProduceKt.produce$default(GlobalScope.INSTANCE, coroutineContext, 0, null, ChannelsKt.consumesAll(receiveChannel, receiveChannel2), new C01172(receiveChannel2, receiveChannel, function2, null), 6, null); } public static final Function1 consumes(final ReceiveChannel receiveChannel) { return new Function1() { // from class: kotlinx.coroutines.channels.ChannelsKt__DeprecatedKt.consumes.1 /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ { super(1); } @Override // kotlin.jvm.functions.Function1 public /* bridge */ /* synthetic */ Unit invoke(Throwable th) { invoke2(th); return Unit.INSTANCE; } /* JADX INFO: renamed from: invoke, reason: avoid collision after fix types in other method */ public final void invoke2(Throwable th) { ChannelsKt.cancelConsumed(receiveChannel, th); } }; } }