.class public Lkotlinx/coroutines/channels/k; .super Lkotlinx/coroutines/a; .source "Broadcast.kt" # interfaces .implements Lkotlinx/coroutines/channels/x; .implements Lkotlinx/coroutines/channels/i; # annotations .annotation system Ldalvik/annotation/Signature; value = { "", "Lkotlinx/coroutines/a<", "Lkotlin/d1;", ">;", "Lkotlinx/coroutines/channels/x<", "TE;>;", "Lkotlinx/coroutines/channels/i<", "TE;>;" } .end annotation .annotation system Ldalvik/annotation/SourceDebugExtension; value = "SMAP\nBroadcast.kt\nKotlin\n*S Kotlin\n*F\n+ 1 Broadcast.kt\nkotlinx/coroutines/channels/BroadcastCoroutine\n+ 2 JobSupport.kt\nkotlinx/coroutines/JobSupport\n*L\n1#1,188:1\n699#2,2:189\n699#2,2:191\n*E\n*S KotlinDebug\n*F\n+ 1 Broadcast.kt\nkotlinx/coroutines/channels/BroadcastCoroutine\n*L\n138#1,2:189\n143#1,2:191\n*E\n" .end annotation .annotation runtime Lkotlin/Metadata; bv = {} d1 = { "\u0000Z\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0003\n\u0000\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0008\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0006\n\u0002\u0018\u0002\n\u0002\u0008\t\n\u0002\u0018\u0002\n\u0002\u0008\u0007\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0002\u0008\u0005\u0008\u0012\u0018\u0000*\u0004\u0008\u0000\u0010\u00012\u0008\u0012\u0004\u0012\u00020\u00030\u00022\u0008\u0012\u0004\u0012\u00028\u00000\u00042\u0008\u0012\u0004\u0012\u00028\u00000\u0005B%\u0012\u0006\u00103\u001a\u000202\u0012\u000c\u0010#\u001a\u0008\u0012\u0004\u0012\u00028\u00000\u0005\u0012\u0006\u00104\u001a\u00020\u0008\u00a2\u0006\u0004\u00085\u00106J\u0012\u0010\t\u001a\u00020\u00082\u0008\u0010\u0007\u001a\u0004\u0018\u00010\u0006H\u0007J\u0016\u0010\u000c\u001a\u00020\u00032\u000e\u0010\u0007\u001a\n\u0018\u00010\nj\u0004\u0018\u0001`\u000bJ\u0010\u0010\r\u001a\u00020\u00032\u0006\u0010\u0007\u001a\u00020\u0006H\u0016J\u0017\u0010\u000f\u001a\u00020\u00032\u0006\u0010\u000e\u001a\u00020\u0003H\u0014\u00a2\u0006\u0004\u0008\u000f\u0010\u0010J\u0018\u0010\u0012\u001a\u00020\u00032\u0006\u0010\u0007\u001a\u00020\u00062\u0006\u0010\u0011\u001a\u00020\u0008H\u0014J\u0012\u0010\u0013\u001a\u00020\u00082\u0008\u0010\u0007\u001a\u0004\u0018\u00010\u0006H\u0016J.\u0010\u0018\u001a\u00020\u00032#\u0010\u0017\u001a\u001f\u0012\u0015\u0012\u0013\u0018\u00010\u0006\u00a2\u0006\u000c\u0008\u0015\u0012\u0008\u0008\u0016\u0012\u0004\u0008\u0008(\u0007\u0012\u0004\u0012\u00020\u00030\u0014H\u0097\u0001J\u0018\u0010\u001a\u001a\u00020\u00082\u0006\u0010\u0019\u001a\u00028\u0000H\u0096\u0001\u00a2\u0006\u0004\u0008\u001a\u0010\u001bJ\u000f\u0010\u001d\u001a\u0008\u0012\u0004\u0012\u00028\u00000\u001cH\u0096\u0001J\u001b\u0010\u0001\u001a\u00020\u00032\u0006\u0010\u0019\u001a\u00028\u0000H\u0096A\u00f8\u0001\u0000\u00a2\u0006\u0004\u0008\u0001\u0010\u001eR \u0010#\u001a\u0008\u0012\u0004\u0012\u00028\u00000\u00058\u0004X\u0084\u0004\u00a2\u0006\u000c\n\u0004\u0008\u001f\u0010 \u001a\u0004\u0008!\u0010\"R\u0014\u0010$\u001a\u00020\u00088VX\u0096\u0004\u00a2\u0006\u0006\u001a\u0004\u0008$\u0010%R\u001a\u0010)\u001a\u0008\u0012\u0004\u0012\u00028\u00000&8VX\u0096\u0004\u00a2\u0006\u0006\u001a\u0004\u0008\'\u0010(R\u0014\u0010+\u001a\u00020\u00088\u0016X\u0097\u0005\u00a2\u0006\u0006\u001a\u0004\u0008*\u0010%R\u0014\u0010-\u001a\u00020\u00088\u0016X\u0097\u0005\u00a2\u0006\u0006\u001a\u0004\u0008,\u0010%R&\u00101\u001a\u0014\u0012\u0004\u0012\u00028\u0000\u0012\n\u0012\u0008\u0012\u0004\u0012\u00028\u00000&0.8\u0016X\u0096\u0005\u00a2\u0006\u0006\u001a\u0004\u0008/\u00100\u0082\u0002\u0004\n\u0002\u0008\u0019\u00a8\u00067" } d2 = { "Lkotlinx/coroutines/channels/k;", "E", "Lkotlinx/coroutines/a;", "Lkotlin/d1;", "Lkotlinx/coroutines/channels/x;", "Lkotlinx/coroutines/channels/i;", "", "cause", "", "a", "Ljava/util/concurrent/CancellationException;", "Lkotlinx/coroutines/CancellationException;", "b", "V", "value", "t1", "(Lkotlin/d1;)V", "handled", "n1", "A", "Lkotlin/Function1;", "Lkotlin/ParameterName;", "name", "handler", "H", "element", "offer", "(Ljava/lang/Object;)Z", "Lkotlinx/coroutines/channels/z;", "q", "(Ljava/lang/Object;Lkotlin/coroutines/c;)Ljava/lang/Object;", "d", "Lkotlinx/coroutines/channels/i;", "s1", "()Lkotlinx/coroutines/channels/i;", "_channel", "isActive", "()Z", "Lkotlinx/coroutines/channels/d0;", "c", "()Lkotlinx/coroutines/channels/d0;", "channel", "F", "isClosedForSend", "m", "isFull", "Lkotlinx/coroutines/selects/e;", "o", "()Lkotlinx/coroutines/selects/e;", "onSend", "Lkotlin/coroutines/CoroutineContext;", "parentContext", "active", "", "(Lkotlin/coroutines/CoroutineContext;Lkotlinx/coroutines/channels/i;Z)V", "kotlinx-coroutines-core" } k = 0x1 mv = { 0x1, 0x4, 0x0 } .end annotation # instance fields .field public final d:Lkotlinx/coroutines/channels/i; .annotation system Ldalvik/annotation/Signature; value = { "Lkotlinx/coroutines/channels/i<", "TE;>;" } .end annotation .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end field # direct methods .method public constructor (Lkotlin/coroutines/CoroutineContext;Lkotlinx/coroutines/channels/i;Z)V .locals 0 .param p1 # Lkotlin/coroutines/CoroutineContext; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .param p2 # Lkotlinx/coroutines/channels/i; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkotlin/coroutines/CoroutineContext;", "Lkotlinx/coroutines/channels/i<", "TE;>;Z)V" } .end annotation .line 1 invoke-direct {p0, p1, p3}, Lkotlinx/coroutines/a;->(Lkotlin/coroutines/CoroutineContext;Z)V iput-object p2, p0, Lkotlinx/coroutines/channels/k;->d:Lkotlinx/coroutines/channels/i; return-void .end method .method public static synthetic u1(Lkotlinx/coroutines/channels/k;Ljava/lang/Object;Lkotlin/coroutines/c;)Ljava/lang/Object; .locals 0 iget-object p0, p0, Lkotlinx/coroutines/channels/k;->d:Lkotlinx/coroutines/channels/i; invoke-interface {p0, p1, p2}, Lkotlinx/coroutines/channels/d0;->E(Ljava/lang/Object;Lkotlin/coroutines/c;)Ljava/lang/Object; move-result-object p0 return-object p0 .end method # virtual methods .method public A(Ljava/lang/Throwable;)Z .locals 1 .param p1 # Ljava/lang/Throwable; .annotation build Lorg/jetbrains/annotations/Nullable; .end annotation .end param .line 1 iget-object v0, p0, Lkotlinx/coroutines/channels/k;->d:Lkotlinx/coroutines/channels/i; invoke-interface {v0, p1}, Lkotlinx/coroutines/channels/d0;->A(Ljava/lang/Throwable;)Z move-result p1 .line 2 invoke-virtual {p0}, Lkotlinx/coroutines/JobSupport;->start()Z return p1 .end method .method public E(Ljava/lang/Object;Lkotlin/coroutines/c;)Ljava/lang/Object; .locals 0 .param p2 # Lkotlin/coroutines/c; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(TE;", "Lkotlin/coroutines/c<", "-", "Lkotlin/d1;", ">;)", "Ljava/lang/Object;" } .end annotation .annotation build Lorg/jetbrains/annotations/Nullable; .end annotation invoke-static {p0, p1, p2}, Lkotlinx/coroutines/channels/k;->u1(Lkotlinx/coroutines/channels/k;Ljava/lang/Object;Lkotlin/coroutines/c;)Ljava/lang/Object; move-result-object p1 return-object p1 .end method .method public F()Z .locals 1 iget-object v0, p0, Lkotlinx/coroutines/channels/k;->d:Lkotlinx/coroutines/channels/i; invoke-interface {v0}, Lkotlinx/coroutines/channels/d0;->F()Z move-result v0 return v0 .end method .method public H(Lej/l;)V .locals 1 .param p1 # Lej/l; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lej/l<", "-", "Ljava/lang/Throwable;", "Lkotlin/d1;", ">;)V" } .end annotation .annotation build Lkotlinx/coroutines/ExperimentalCoroutinesApi; .end annotation iget-object v0, p0, Lkotlinx/coroutines/channels/k;->d:Lkotlinx/coroutines/channels/i; invoke-interface {v0, p1}, Lkotlinx/coroutines/channels/d0;->H(Lej/l;)V return-void .end method .method public V(Ljava/lang/Throwable;)V .locals 2 .param p1 # Ljava/lang/Throwable; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param const/4 v0, 0x0 const/4 v1, 0x1 .line 1 invoke-static {p0, p1, v0, v1, v0}, Lkotlinx/coroutines/JobSupport;->b1(Lkotlinx/coroutines/JobSupport;Ljava/lang/Throwable;Ljava/lang/String;ILjava/lang/Object;)Ljava/util/concurrent/CancellationException; move-result-object p1 .line 2 iget-object v0, p0, Lkotlinx/coroutines/channels/k;->d:Lkotlinx/coroutines/channels/i; invoke-interface {v0, p1}, Lkotlinx/coroutines/channels/i;->b(Ljava/util/concurrent/CancellationException;)V .line 3 invoke-virtual {p0, p1}, Lkotlinx/coroutines/JobSupport;->T(Ljava/lang/Throwable;)Z return-void .end method .method public final synthetic a(Ljava/lang/Throwable;)Z .locals 2 .param p1 # Ljava/lang/Throwable; .annotation build Lorg/jetbrains/annotations/Nullable; .end annotation .end param .annotation runtime Lkotlin/Deprecated; level = .enum Lkotlin/DeprecationLevel;->HIDDEN:Lkotlin/DeprecationLevel; message = "Since 1.2.0, binary compatibility with versions <= 1.1.x" .end annotation if-eqz p1, :cond_0 goto :goto_0 :cond_0 const/4 p1, 0x0 .line 1 new-instance v0, Lkotlinx/coroutines/JobCancellationException; invoke-static {p0}, Lkotlinx/coroutines/JobSupport;->J(Lkotlinx/coroutines/JobSupport;)Ljava/lang/String; move-result-object v1 invoke-direct {v0, v1, p1, p0}, Lkotlinx/coroutines/JobCancellationException;->(Ljava/lang/String;Ljava/lang/Throwable;Lkotlinx/coroutines/y1;)V move-object p1, v0 .line 2 :goto_0 invoke-virtual {p0, p1}, Lkotlinx/coroutines/channels/k;->V(Ljava/lang/Throwable;)V const/4 p1, 0x1 return p1 .end method .method public final b(Ljava/util/concurrent/CancellationException;)V .locals 2 .param p1 # Ljava/util/concurrent/CancellationException; .annotation build Lorg/jetbrains/annotations/Nullable; .end annotation .end param if-eqz p1, :cond_0 goto :goto_0 :cond_0 const/4 p1, 0x0 .line 1 new-instance v0, Lkotlinx/coroutines/JobCancellationException; invoke-static {p0}, Lkotlinx/coroutines/JobSupport;->J(Lkotlinx/coroutines/JobSupport;)Ljava/lang/String; move-result-object v1 invoke-direct {v0, v1, p1, p0}, Lkotlinx/coroutines/JobCancellationException;->(Ljava/lang/String;Ljava/lang/Throwable;Lkotlinx/coroutines/y1;)V move-object p1, v0 .line 2 :goto_0 invoke-virtual {p0, p1}, Lkotlinx/coroutines/channels/k;->V(Ljava/lang/Throwable;)V return-void .end method .method public c()Lkotlinx/coroutines/channels/d0; .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkotlinx/coroutines/channels/d0<", "TE;>;" } .end annotation .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation return-object p0 .end method .method public isActive()Z .locals 1 .line 1 invoke-super {p0}, Lkotlinx/coroutines/a;->isActive()Z move-result v0 return v0 .end method .method public m()Z .locals 1 iget-object v0, p0, Lkotlinx/coroutines/channels/k;->d:Lkotlinx/coroutines/channels/i; invoke-interface {v0}, Lkotlinx/coroutines/channels/d0;->m()Z move-result v0 return v0 .end method .method public n1(Ljava/lang/Throwable;Z)V .locals 1 .param p1 # Ljava/lang/Throwable; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .line 1 iget-object v0, p0, Lkotlinx/coroutines/channels/k;->d:Lkotlinx/coroutines/channels/i; invoke-interface {v0, p1}, Lkotlinx/coroutines/channels/d0;->A(Ljava/lang/Throwable;)Z move-result v0 if-nez v0, :cond_0 if-nez p2, :cond_0 .line 2 invoke-virtual {p0}, Lkotlinx/coroutines/a;->getContext()Lkotlin/coroutines/CoroutineContext; move-result-object p2 invoke-static {p2, p1}, Lkotlinx/coroutines/k0;->b(Lkotlin/coroutines/CoroutineContext;Ljava/lang/Throwable;)V :cond_0 return-void .end method .method public o()Lkotlinx/coroutines/selects/e; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkotlinx/coroutines/selects/e<", "TE;", "Lkotlinx/coroutines/channels/d0<", "TE;>;>;" } .end annotation .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation iget-object v0, p0, Lkotlinx/coroutines/channels/k;->d:Lkotlinx/coroutines/channels/i; invoke-interface {v0}, Lkotlinx/coroutines/channels/d0;->o()Lkotlinx/coroutines/selects/e; move-result-object v0 return-object v0 .end method .method public bridge synthetic o1(Ljava/lang/Object;)V .locals 0 .line 1 check-cast p1, Lkotlin/d1; invoke-virtual {p0, p1}, Lkotlinx/coroutines/channels/k;->t1(Lkotlin/d1;)V return-void .end method .method public offer(Ljava/lang/Object;)Z .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(TE;)Z" } .end annotation iget-object v0, p0, Lkotlinx/coroutines/channels/k;->d:Lkotlinx/coroutines/channels/i; invoke-interface {v0, p1}, Lkotlinx/coroutines/channels/d0;->offer(Ljava/lang/Object;)Z move-result p1 return p1 .end method .method public q()Lkotlinx/coroutines/channels/z; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkotlinx/coroutines/channels/z<", "TE;>;" } .end annotation .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation iget-object v0, p0, Lkotlinx/coroutines/channels/k;->d:Lkotlinx/coroutines/channels/i; invoke-interface {v0}, Lkotlinx/coroutines/channels/i;->q()Lkotlinx/coroutines/channels/z; move-result-object v0 return-object v0 .end method .method public final s1()Lkotlinx/coroutines/channels/i; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()", "Lkotlinx/coroutines/channels/i<", "TE;>;" } .end annotation .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .line 1 iget-object v0, p0, Lkotlinx/coroutines/channels/k;->d:Lkotlinx/coroutines/channels/i; return-object v0 .end method .method public t1(Lkotlin/d1;)V .locals 2 .param p1 # Lkotlin/d1; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .line 1 iget-object p1, p0, Lkotlinx/coroutines/channels/k;->d:Lkotlinx/coroutines/channels/i; const/4 v0, 0x0 const/4 v1, 0x1 invoke-static {p1, v0, v1, v0}, Lkotlinx/coroutines/channels/d0$a;->a(Lkotlinx/coroutines/channels/d0;Ljava/lang/Throwable;ILjava/lang/Object;)Z return-void .end method