package kotlinx.coroutines.channels; import java.util.concurrent.CancellationException; import kotlin.Deprecated; import kotlin.DeprecationLevel; import kotlin.Metadata; import kotlin.ReplaceWith; import kotlin.Unit; import kotlin.coroutines.Continuation; import kotlin.jvm.functions.Function1; import kotlin.jvm.internal.InlineMarker; import kotlin.jvm.internal.Intrinsics; import kotlinx.coroutines.ExceptionsKt; import kotlinx.coroutines.channels.ReceiveChannel; import kotlinx.coroutines.selects.SelectClause1; /* JADX INFO: Access modifiers changed from: package-private */ /* compiled from: Channels.common.kt */ @Metadata(d1 = {"\u0000>\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0010\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0003\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0003\n\u0002\u0010 \n\u0000\u001a\u001a\u0010\u0002\u001a\u00020\u0003*\u0006\u0012\u0002\b\u00030\u00042\b\u0010\u0005\u001a\u0004\u0018\u00010\u0006H\u0001\u001aC\u0010\u0007\u001a\u0002H\b\"\u0004\b\u0000\u0010\t\"\u0004\b\u0001\u0010\b*\b\u0012\u0004\u0012\u0002H\t0\n2\u001d\u0010\u000b\u001a\u0019\u0012\n\u0012\b\u0012\u0004\u0012\u0002H\t0\u0004\u0012\u0004\u0012\u0002H\b0\f¢\u0006\u0002\b\rH\u0087\b¢\u0006\u0002\u0010\u000e\u001aP\u0010\u0007\u001a\u0002H\b\"\u0004\b\u0000\u0010\t\"\u0004\b\u0001\u0010\b*\b\u0012\u0004\u0012\u0002H\t0\u00042\u001d\u0010\u000b\u001a\u0019\u0012\n\u0012\b\u0012\u0004\u0012\u0002H\t0\u0004\u0012\u0004\u0012\u0002H\b0\f¢\u0006\u0002\b\rH\u0086\b\u0082\u0002\n\n\b\b\u0001\u0012\u0002\u0010\u0001 \u0001¢\u0006\u0002\u0010\u000f\u001a5\u0010\u0010\u001a\u00020\u0003\"\u0004\b\u0000\u0010\t*\b\u0012\u0004\u0012\u0002H\t0\n2\u0012\u0010\u0011\u001a\u000e\u0012\u0004\u0012\u0002H\t\u0012\u0004\u0012\u00020\u00030\fH\u0087Hø\u0001\u0000¢\u0006\u0002\u0010\u0012\u001a5\u0010\u0010\u001a\u00020\u0003\"\u0004\b\u0000\u0010\t*\b\u0012\u0004\u0012\u0002H\t0\u00042\u0012\u0010\u0011\u001a\u000e\u0012\u0004\u0012\u0002H\t\u0012\u0004\u0012\u00020\u00030\fH\u0086Hø\u0001\u0000¢\u0006\u0002\u0010\u0013\u001a$\u0010\u0014\u001a\n\u0012\u0006\u0012\u0004\u0018\u0001H\t0\u0015\"\b\b\u0000\u0010\t*\u00020\u0016*\b\u0012\u0004\u0012\u0002H\t0\u0004H\u0007\u001a'\u0010\u0017\u001a\u0004\u0018\u0001H\t\"\b\b\u0000\u0010\t*\u00020\u0016*\b\u0012\u0004\u0012\u0002H\t0\u0004H\u0087@ø\u0001\u0000¢\u0006\u0002\u0010\u0018\u001a'\u0010\u0019\u001a\b\u0012\u0004\u0012\u0002H\t0\u001a\"\u0004\b\u0000\u0010\t*\b\u0012\u0004\u0012\u0002H\t0\u0004H\u0086@ø\u0001\u0000¢\u0006\u0002\u0010\u0018\"\u000e\u0010\u0000\u001a\u00020\u0001X\u0080T¢\u0006\u0002\n\u0000\u0082\u0002\u0004\n\u0002\b\u0019¨\u0006\u001b"}, d2 = {"DEFAULT_CLOSE_MESSAGE", "", "cancelConsumed", "", "Lkotlinx/coroutines/channels/ReceiveChannel;", "cause", "", "consume", "R", "E", "Lkotlinx/coroutines/channels/BroadcastChannel;", "block", "Lkotlin/Function1;", "Lkotlin/ExtensionFunctionType;", "(Lkotlinx/coroutines/channels/BroadcastChannel;Lkotlin/jvm/functions/Function1;)Ljava/lang/Object;", "(Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/jvm/functions/Function1;)Ljava/lang/Object;", "consumeEach", "action", "(Lkotlinx/coroutines/channels/BroadcastChannel;Lkotlin/jvm/functions/Function1;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "(Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/jvm/functions/Function1;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "onReceiveOrNull", "Lkotlinx/coroutines/selects/SelectClause1;", "", "receiveOrNull", "(Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "toList", "", "kotlinx-coroutines-core"}, k = 5, mv = {1, 8, 0}, xi = 48, xs = "kotlinx/coroutines/channels/ChannelsKt") /* loaded from: classes6.dex */ public final /* synthetic */ class ChannelsKt__Channels_commonKt { @Deprecated(level = DeprecationLevel.WARNING, message = "BroadcastChannel is deprecated in the favour of SharedFlow and is no longer supported") public static final R consume(BroadcastChannel broadcastChannel, Function1, ? extends R> function1) { ReceiveChannel openSubscription = broadcastChannel.openSubscription(); try { return function1.invoke(openSubscription); } finally { InlineMarker.finallyStart(1); ReceiveChannel.DefaultImpls.cancel$default((ReceiveChannel) openSubscription, (CancellationException) null, 1, (Object) null); InlineMarker.finallyEnd(1); } } @Deprecated(level = DeprecationLevel.HIDDEN, message = "Deprecated in the favour of 'receiveCatching'", replaceWith = @ReplaceWith(expression = "receiveCatching().getOrNull()", imports = {})) public static final /* synthetic */ Object receiveOrNull(ReceiveChannel receiveChannel, Continuation continuation) { Intrinsics.checkNotNull(receiveChannel, "null cannot be cast to non-null type kotlinx.coroutines.channels.ReceiveChannel"); return receiveChannel.receiveOrNull(continuation); } @Deprecated(level = DeprecationLevel.HIDDEN, message = "Deprecated in the favour of 'onReceiveCatching'") public static final /* synthetic */ SelectClause1 onReceiveOrNull(ReceiveChannel receiveChannel) { Intrinsics.checkNotNull(receiveChannel, "null cannot be cast to non-null type kotlinx.coroutines.channels.ReceiveChannel"); return receiveChannel.getOnReceiveOrNull(); } public static final R consume(ReceiveChannel receiveChannel, Function1, ? extends R> function1) { try { R invoke = function1.invoke(receiveChannel); InlineMarker.finallyStart(1); ChannelsKt.cancelConsumed(receiveChannel, null); InlineMarker.finallyEnd(1); return invoke; } finally { } } /* JADX WARN: Removed duplicated region for block: B:10:0x0024 */ /* JADX WARN: Removed duplicated region for block: B:18:0x0040 */ /* JADX WARN: Removed duplicated region for block: B:23:0x0059 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:24:0x005a */ /* JADX WARN: Removed duplicated region for block: B:27:0x0065 A[Catch: all -> 0x0036, TryCatch #1 {all -> 0x0036, blocks: (B:12:0x0032, B:25:0x005d, B:27:0x0065, B:21:0x004b, B:28:0x006e), top: B:39:0x0032 }] */ /* JADX WARN: Removed duplicated region for block: B:28:0x006e A[Catch: all -> 0x0036, TRY_LEAVE, TryCatch #1 {all -> 0x0036, blocks: (B:12:0x0032, B:25:0x005d, B:27:0x0065, B:21:0x004b, B:28:0x006e), top: B:39:0x0032 }] */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:24:0x005a -> B:25:0x005d). Please submit an issue!!! */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final java.lang.Object consumeEach(kotlinx.coroutines.channels.ReceiveChannel r5, kotlin.jvm.functions.Function1 r6, kotlin.coroutines.Continuation r7) { /* boolean r0 = r7 instanceof kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt$consumeEach$1 if (r0 == 0) goto L14 r0 = r7 kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt$consumeEach$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt$consumeEach$1) r0 int r1 = r0.label r2 = -2147483648(0xffffffff80000000, float:-0.0) r1 = r1 & r2 if (r1 == 0) goto L14 int r7 = r0.label int r7 = r7 - r2 r0.label = r7 goto L19 L14: kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt$consumeEach$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt$consumeEach$1 r0.(r7) L19: java.lang.Object r7 = r0.result java.lang.Object r1 = kotlin.coroutines.intrinsics.IntrinsicsKt.getCOROUTINE_SUSPENDED() int r2 = r0.label r3 = 1 if (r2 == 0) goto L40 if (r2 != r3) goto L38 java.lang.Object r5 = r0.L$2 kotlinx.coroutines.channels.ChannelIterator r5 = (kotlinx.coroutines.channels.ChannelIterator) r5 java.lang.Object r6 = r0.L$1 kotlinx.coroutines.channels.ReceiveChannel r6 = (kotlinx.coroutines.channels.ReceiveChannel) r6 java.lang.Object r2 = r0.L$0 kotlin.jvm.functions.Function1 r2 = (kotlin.jvm.functions.Function1) r2 kotlin.ResultKt.throwOnFailure(r7) // Catch: java.lang.Throwable -> L36 goto L5d L36: r5 = move-exception goto L81 L38: java.lang.IllegalStateException r5 = new java.lang.IllegalStateException java.lang.String r6 = "call to 'resume' before 'invoke' with coroutine" r5.(r6) throw r5 L40: kotlin.ResultKt.throwOnFailure(r7) kotlinx.coroutines.channels.ChannelIterator r7 = r5.iterator() // Catch: java.lang.Throwable -> L7d r4 = r6 r6 = r5 r5 = r7 r7 = r4 L4b: r0.L$0 = r7 // Catch: java.lang.Throwable -> L36 r0.L$1 = r6 // Catch: java.lang.Throwable -> L36 r0.L$2 = r5 // Catch: java.lang.Throwable -> L36 r0.label = r3 // Catch: java.lang.Throwable -> L36 java.lang.Object r2 = r5.hasNext(r0) // Catch: java.lang.Throwable -> L36 if (r2 != r1) goto L5a return r1 L5a: r4 = r2 r2 = r7 r7 = r4 L5d: java.lang.Boolean r7 = (java.lang.Boolean) r7 // Catch: java.lang.Throwable -> L36 boolean r7 = r7.booleanValue() // Catch: java.lang.Throwable -> L36 if (r7 == 0) goto L6e java.lang.Object r7 = r5.next() // Catch: java.lang.Throwable -> L36 r2.invoke(r7) // Catch: java.lang.Throwable -> L36 r7 = r2 goto L4b L6e: kotlin.Unit r5 = kotlin.Unit.INSTANCE // Catch: java.lang.Throwable -> L36 kotlin.jvm.internal.InlineMarker.finallyStart(r3) r5 = 0 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r6, r5) kotlin.jvm.internal.InlineMarker.finallyEnd(r3) kotlin.Unit r5 = kotlin.Unit.INSTANCE return r5 L7d: r6 = move-exception r4 = r6 r6 = r5 r5 = r4 L81: throw r5 // Catch: java.lang.Throwable -> L82 L82: r7 = move-exception kotlin.jvm.internal.InlineMarker.finallyStart(r3) kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r6, r5) kotlin.jvm.internal.InlineMarker.finallyEnd(r3) throw r7 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt.consumeEach(kotlinx.coroutines.channels.ReceiveChannel, kotlin.jvm.functions.Function1, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:10:0x0024 */ /* JADX WARN: Removed duplicated region for block: B:18:0x0045 */ /* 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 -> 0x003a, TryCatch #2 {all -> 0x003a, blocks: (B:12:0x0036, B:25:0x0068, B:27:0x0070, B:28:0x0079), top: B:43:0x0036 }] */ /* JADX WARN: Removed duplicated region for block: B:28:0x0079 A[Catch: all -> 0x003a, TRY_LEAVE, TryCatch #2 {all -> 0x003a, blocks: (B:12:0x0036, B:25:0x0068, B:27:0x0070, B:28:0x0079), top: B:43:0x0036 }] */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:24:0x0065 -> B:25:0x0068). Please submit an issue!!! */ /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final java.lang.Object toList(kotlinx.coroutines.channels.ReceiveChannel r7, kotlin.coroutines.Continuation> r8) { /* boolean r0 = r8 instanceof kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt$toList$1 if (r0 == 0) goto L14 r0 = r8 kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt$toList$1 r0 = (kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt$toList$1) 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__Channels_commonKt$toList$1 r0 = new kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt$toList$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 = 1 if (r2 == 0) goto L45 if (r2 != r3) goto L3d java.lang.Object r7 = r0.L$3 kotlinx.coroutines.channels.ChannelIterator r7 = (kotlinx.coroutines.channels.ChannelIterator) r7 java.lang.Object r2 = r0.L$2 kotlinx.coroutines.channels.ReceiveChannel r2 = (kotlinx.coroutines.channels.ReceiveChannel) r2 java.lang.Object r4 = r0.L$1 java.util.List r4 = (java.util.List) r4 java.lang.Object r5 = r0.L$0 java.util.List r5 = (java.util.List) r5 kotlin.ResultKt.throwOnFailure(r8) // Catch: java.lang.Throwable -> L3a goto L68 L3a: r7 = move-exception r8 = r2 goto L8a 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: kotlin.ResultKt.throwOnFailure(r8) java.util.List r8 = kotlin.collections.CollectionsKt.createListBuilder() kotlinx.coroutines.channels.ChannelIterator r2 = r7.iterator() // Catch: java.lang.Throwable -> L86 r4 = r8 r5 = r4 r8 = r7 r7 = r2 L54: r0.L$0 = r5 // Catch: java.lang.Throwable -> L84 r0.L$1 = r4 // Catch: java.lang.Throwable -> L84 r0.L$2 = r8 // Catch: java.lang.Throwable -> L84 r0.L$3 = r7 // Catch: java.lang.Throwable -> L84 r0.label = r3 // Catch: java.lang.Throwable -> L84 java.lang.Object r2 = r7.hasNext(r0) // Catch: java.lang.Throwable -> L84 if (r2 != r1) goto L65 return r1 L65: r6 = r2 r2 = r8 r8 = r6 L68: java.lang.Boolean r8 = (java.lang.Boolean) r8 // Catch: java.lang.Throwable -> L3a boolean r8 = r8.booleanValue() // Catch: java.lang.Throwable -> L3a if (r8 == 0) goto L79 java.lang.Object r8 = r7.next() // Catch: java.lang.Throwable -> L3a r4.add(r8) // Catch: java.lang.Throwable -> L3a r8 = r2 goto L54 L79: kotlin.Unit r7 = kotlin.Unit.INSTANCE // Catch: java.lang.Throwable -> L3a r7 = 0 kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r2, r7) java.util.List r7 = kotlin.collections.CollectionsKt.build(r5) return r7 L84: r7 = move-exception goto L8a L86: r8 = move-exception r6 = r8 r8 = r7 r7 = r6 L8a: throw r7 // Catch: java.lang.Throwable -> L8b L8b: r0 = move-exception kotlinx.coroutines.channels.ChannelsKt.cancelConsumed(r8, r7) throw r0 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt.toList(kotlinx.coroutines.channels.ReceiveChannel, kotlin.coroutines.Continuation):java.lang.Object"); } /* JADX WARN: Removed duplicated region for block: B:10:0x0025 */ /* JADX WARN: Removed duplicated region for block: B:19:0x0046 */ /* JADX WARN: Removed duplicated region for block: B:24:0x0062 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:25:0x0063 */ /* JADX WARN: Removed duplicated region for block: B:28:0x006f A[Catch: all -> 0x0088, TryCatch #0 {all -> 0x0088, blocks: (B:26:0x0067, B:28:0x006f, B:29:0x007a), top: B:40:0x0067 }] */ /* JADX WARN: Removed duplicated region for block: B:29:0x007a A[Catch: all -> 0x0088, TRY_LEAVE, TryCatch #0 {all -> 0x0088, blocks: (B:26:0x0067, B:28:0x006f, B:29:0x007a), top: B:40:0x0067 }] */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:25:0x0063 -> B:14:0x0039). Please submit an issue!!! */ @kotlin.Deprecated(level = kotlin.DeprecationLevel.WARNING, message = "BroadcastChannel is deprecated in the favour of SharedFlow and is no longer supported") /* Code decompiled incorrectly, please refer to instructions dump. To view partially-correct add '--show-bad-code' argument */ public static final java.lang.Object consumeEach(kotlinx.coroutines.channels.BroadcastChannel r6, kotlin.jvm.functions.Function1 r7, kotlin.coroutines.Continuation r8) { /* boolean r0 = r8 instanceof kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt$consumeEach$3 if (r0 == 0) goto L14 r0 = r8 kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt$consumeEach$3 r0 = (kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt$consumeEach$3) 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__Channels_commonKt$consumeEach$3 r0 = new kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt$consumeEach$3 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 L46 if (r2 != r4) goto L3e 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 kotlin.jvm.functions.Function1 r2 = (kotlin.jvm.functions.Function1) r2 kotlin.ResultKt.throwOnFailure(r8) // Catch: java.lang.Throwable -> L3c r5 = r0 r0 = r7 r7 = r2 L39: r2 = r1 r1 = r5 goto L67 L3c: r6 = move-exception goto L92 L3e: java.lang.IllegalStateException r6 = new java.lang.IllegalStateException java.lang.String r7 = "call to 'resume' before 'invoke' with coroutine" r6.(r7) throw r6 L46: kotlin.ResultKt.throwOnFailure(r8) kotlinx.coroutines.channels.ReceiveChannel r6 = r6.openSubscription() kotlinx.coroutines.channels.ChannelIterator r8 = r6.iterator() // Catch: java.lang.Throwable -> L8e r5 = r8 r8 = r6 r6 = r5 L54: r0.L$0 = r7 // Catch: java.lang.Throwable -> L8b r0.L$1 = r8 // Catch: java.lang.Throwable -> L8b r0.L$2 = r6 // Catch: java.lang.Throwable -> L8b r0.label = r4 // Catch: java.lang.Throwable -> L8b java.lang.Object r2 = r6.hasNext(r0) // Catch: java.lang.Throwable -> L8b if (r2 != r1) goto L63 return r1 L63: r5 = r0 r0 = r8 r8 = r2 goto L39 L67: java.lang.Boolean r8 = (java.lang.Boolean) r8 // Catch: java.lang.Throwable -> L88 boolean r8 = r8.booleanValue() // Catch: java.lang.Throwable -> L88 if (r8 == 0) goto L7a java.lang.Object r8 = r6.next() // Catch: java.lang.Throwable -> L88 r7.invoke(r8) // Catch: java.lang.Throwable -> L88 r8 = r0 r0 = r1 r1 = r2 goto L54 L7a: kotlin.Unit r6 = kotlin.Unit.INSTANCE // Catch: java.lang.Throwable -> L88 kotlin.jvm.internal.InlineMarker.finallyStart(r4) kotlinx.coroutines.channels.ReceiveChannel.DefaultImpls.cancel$default(r0, r3, r4, r3) kotlin.jvm.internal.InlineMarker.finallyEnd(r4) kotlin.Unit r6 = kotlin.Unit.INSTANCE return r6 L88: r6 = move-exception r7 = r0 goto L92 L8b: r6 = move-exception r7 = r8 goto L92 L8e: r7 = move-exception r5 = r7 r7 = r6 r6 = r5 L92: kotlin.jvm.internal.InlineMarker.finallyStart(r4) kotlinx.coroutines.channels.ReceiveChannel.DefaultImpls.cancel$default(r7, r3, r4, r3) kotlin.jvm.internal.InlineMarker.finallyEnd(r4) throw r6 */ throw new UnsupportedOperationException("Method not decompiled: kotlinx.coroutines.channels.ChannelsKt__Channels_commonKt.consumeEach(kotlinx.coroutines.channels.BroadcastChannel, kotlin.jvm.functions.Function1, kotlin.coroutines.Continuation):java.lang.Object"); } public static final void cancelConsumed(ReceiveChannel receiveChannel, Throwable th) { if (th != null) { r0 = th instanceof CancellationException ? (CancellationException) th : null; if (r0 == null) { r0 = ExceptionsKt.CancellationException("Channel was consumed, consumer had failed", th); } } receiveChannel.cancel(r0); } private static final Object consumeEach$$forInline(ReceiveChannel receiveChannel, Function1 function1, Continuation continuation) { try { ReceiveChannel receiveChannel2 = receiveChannel; ChannelIterator it = receiveChannel.iterator(); while (true) { InlineMarker.mark(3); InlineMarker.mark(0); Object hasNext = it.hasNext(null); InlineMarker.mark(1); if (!((Boolean) hasNext).booleanValue()) { Unit unit = Unit.INSTANCE; InlineMarker.finallyStart(1); ChannelsKt.cancelConsumed(receiveChannel, null); InlineMarker.finallyEnd(1); return Unit.INSTANCE; } function1.invoke((E) it.next()); } } finally { } } @Deprecated(level = DeprecationLevel.WARNING, message = "BroadcastChannel is deprecated in the favour of SharedFlow and is no longer supported") private static final Object consumeEach$$forInline(BroadcastChannel broadcastChannel, Function1 function1, Continuation continuation) { ReceiveChannel openSubscription = broadcastChannel.openSubscription(); try { ReceiveChannel receiveChannel = openSubscription; ChannelIterator it = openSubscription.iterator(); while (true) { InlineMarker.mark(3); InlineMarker.mark(0); Object hasNext = it.hasNext(null); InlineMarker.mark(1); if (!((Boolean) hasNext).booleanValue()) { Unit unit = Unit.INSTANCE; InlineMarker.finallyStart(1); ReceiveChannel.DefaultImpls.cancel$default((ReceiveChannel) openSubscription, (CancellationException) null, 1, (Object) null); InlineMarker.finallyEnd(1); return Unit.INSTANCE; } function1.invoke(it.next()); } } catch (Throwable th) { InlineMarker.finallyStart(1); ReceiveChannel.DefaultImpls.cancel$default((ReceiveChannel) openSubscription, (CancellationException) null, 1, (Object) null); InlineMarker.finallyEnd(1); throw th; } } }