.class public final Lkotlinx/coroutines/flow/StartedWhileSubscribed; .super Ljava/lang/Object; .source "SharingStarted.kt" # interfaces .implements Lkotlinx/coroutines/flow/w; # annotations .annotation system Ldalvik/annotation/SourceDebugExtension; value = "SMAP\nSharingStarted.kt\nKotlin\n*S Kotlin\n*F\n+ 1 SharingStarted.kt\nkotlinx/coroutines/flow/StartedWhileSubscribed\n+ 2 fake.kt\nkotlin/jvm/internal/FakeKt\n*L\n1#1,211:1\n1#2:212\n*E\n" .end annotation .annotation runtime Lkotlin/Metadata; bv = {} d1 = { "\u00008\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010\u0008\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\u000b\n\u0002\u0008\u0002\n\u0002\u0010\t\n\u0002\u0008\u0008\u0008\u0002\u0018\u00002\u00020\u0001B\u0017\u0012\u0006\u0010\u0012\u001a\u00020\u000f\u0012\u0006\u0010\u0014\u001a\u00020\u000f\u00a2\u0006\u0004\u0008\u0015\u0010\u0016J\u001c\u0010\u0007\u001a\u0008\u0012\u0004\u0012\u00020\u00060\u00052\u000c\u0010\u0004\u001a\u0008\u0012\u0004\u0012\u00020\u00030\u0002H\u0016J\u0008\u0010\t\u001a\u00020\u0008H\u0016J\u0013\u0010\r\u001a\u00020\u000c2\u0008\u0010\u000b\u001a\u0004\u0018\u00010\nH\u0096\u0002J\u0008\u0010\u000e\u001a\u00020\u0003H\u0016R\u0014\u0010\u0012\u001a\u00020\u000f8\u0002X\u0082\u0004\u00a2\u0006\u0006\n\u0004\u0008\u0010\u0010\u0011R\u0014\u0010\u0014\u001a\u00020\u000f8\u0002X\u0082\u0004\u00a2\u0006\u0006\n\u0004\u0008\u0013\u0010\u0011\u00a8\u0006\u0017" } d2 = { "Lkotlinx/coroutines/flow/StartedWhileSubscribed;", "Lkotlinx/coroutines/flow/w;", "Lkotlinx/coroutines/flow/z;", "", "subscriptionCount", "Lkotlinx/coroutines/flow/f;", "Lkotlinx/coroutines/flow/SharingCommand;", "a", "", "toString", "", "other", "", "equals", "hashCode", "", "b", "J", "stopTimeout", "c", "replayExpiration", "", "(JJ)V", "kotlinx-coroutines-core" } k = 0x1 mv = { 0x1, 0x4, 0x0 } .end annotation # instance fields .field public final b:J .field public final c:J # direct methods .method public constructor (JJ)V .locals 6 .line 1 invoke-direct {p0}, Ljava/lang/Object;->()V iput-wide p1, p0, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->b:J iput-wide p3, p0, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->c:J const-wide/16 v0, 0x0 cmp-long v2, p1, v0 const/4 v3, 0x1 const/4 v4, 0x0 if-ltz v2, :cond_0 move v2, v3 goto :goto_0 :cond_0 move v2, v4 :goto_0 const-string v5, " ms) cannot be negative" if-eqz v2, :cond_3 cmp-long p1, p3, v0 if-ltz p1, :cond_1 goto :goto_1 :cond_1 move v3, v4 :goto_1 if-eqz v3, :cond_2 return-void :cond_2 const-string p1, "replayExpiration(" .line 2 invoke-static {p1, p3, p4, v5}, Landroidx/concurrent/futures/a;->a(Ljava/lang/String;JLjava/lang/String;)Ljava/lang/String; move-result-object p1 new-instance p2, Ljava/lang/IllegalArgumentException; invoke-virtual {p1}, Ljava/lang/Object;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {p2, p1}, Ljava/lang/IllegalArgumentException;->(Ljava/lang/String;)V throw p2 :cond_3 const-string p3, "stopTimeout(" .line 3 invoke-static {p3, p1, p2, v5}, Landroidx/concurrent/futures/a;->a(Ljava/lang/String;JLjava/lang/String;)Ljava/lang/String; move-result-object p1 new-instance p2, Ljava/lang/IllegalArgumentException; invoke-virtual {p1}, Ljava/lang/Object;->toString()Ljava/lang/String; move-result-object p1 invoke-direct {p2, p1}, Ljava/lang/IllegalArgumentException;->(Ljava/lang/String;)V throw p2 .end method .method public static final synthetic b(Lkotlinx/coroutines/flow/StartedWhileSubscribed;)J .locals 2 .line 1 iget-wide v0, p0, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->c:J return-wide v0 .end method .method public static final synthetic c(Lkotlinx/coroutines/flow/StartedWhileSubscribed;)J .locals 2 .line 1 iget-wide v0, p0, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->b:J return-wide v0 .end method # virtual methods .method public a(Lkotlinx/coroutines/flow/z;)Lkotlinx/coroutines/flow/f; .locals 2 .param p1 # Lkotlinx/coroutines/flow/z; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkotlinx/coroutines/flow/z<", "Ljava/lang/Integer;", ">;)", "Lkotlinx/coroutines/flow/f<", "Lkotlinx/coroutines/flow/SharingCommand;", ">;" } .end annotation .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .line 1 new-instance v0, Lkotlinx/coroutines/flow/StartedWhileSubscribed$command$1; const/4 v1, 0x0 invoke-direct {v0, p0, v1}, Lkotlinx/coroutines/flow/StartedWhileSubscribed$command$1;->(Lkotlinx/coroutines/flow/StartedWhileSubscribed;Lkotlin/coroutines/c;)V invoke-static {p1, v0}, Lkotlinx/coroutines/flow/i;->m2(Lkotlinx/coroutines/flow/f;Lej/q;)Lkotlinx/coroutines/flow/f; move-result-object p1 .line 2 new-instance v0, Lkotlinx/coroutines/flow/StartedWhileSubscribed$command$2; invoke-direct {v0, v1}, Lkotlinx/coroutines/flow/StartedWhileSubscribed$command$2;->(Lkotlin/coroutines/c;)V invoke-static {p1, v0}, Lkotlinx/coroutines/flow/i;->p0(Lkotlinx/coroutines/flow/f;Lej/p;)Lkotlinx/coroutines/flow/f; move-result-object p1 .line 3 invoke-static {p1}, Lkotlinx/coroutines/flow/i;->l0(Lkotlinx/coroutines/flow/f;)Lkotlinx/coroutines/flow/f; move-result-object p1 return-object p1 .end method .method public equals(Ljava/lang/Object;)Z .locals 4 .param p1 # Ljava/lang/Object; .annotation build Lorg/jetbrains/annotations/Nullable; .end annotation .end param .line 1 instance-of v0, p1, Lkotlinx/coroutines/flow/StartedWhileSubscribed; if-eqz v0, :cond_0 iget-wide v0, p0, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->b:J check-cast p1, Lkotlinx/coroutines/flow/StartedWhileSubscribed; iget-wide v2, p1, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->b:J cmp-long v0, v0, v2 if-nez v0, :cond_0 iget-wide v0, p0, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->c:J iget-wide v2, p1, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->c:J cmp-long p1, v0, v2 if-nez p1, :cond_0 const/4 p1, 0x1 goto :goto_0 :cond_0 const/4 p1, 0x0 :goto_0 return p1 .end method .method public hashCode()I .locals 3 .line 1 iget-wide v0, p0, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->b:J invoke-static {v0, v1}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long; move-result-object v0 invoke-virtual {v0}, Ljava/lang/Object;->hashCode()I move-result v0 mul-int/lit8 v0, v0, 0x1f iget-wide v1, p0, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->c:J invoke-static {v1, v2}, Ljava/lang/Long;->valueOf(J)Ljava/lang/Long; move-result-object v1 invoke-virtual {v1}, Ljava/lang/Object;->hashCode()I move-result v1 add-int/2addr v1, v0 return v1 .end method .method public toString()Ljava/lang/String; .locals 11 .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation const/4 v0, 0x2 .line 1 invoke-static {v0}, Lkotlin/collections/w;->j(I)Ljava/util/List; move-result-object v0 .line 2 iget-wide v1, p0, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->b:J const-wide/16 v3, 0x0 cmp-long v1, v1, v3 const-string v2, "ms" if-lez v1, :cond_0 const-string v1, "stopTimeout=" invoke-static {v1}, Landroid/support/v4/media/d;->a(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v1 iget-wide v3, p0, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->b:J invoke-virtual {v1, v3, v4}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder; invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v1 invoke-interface {v0, v1}, Ljava/util/List;->add(Ljava/lang/Object;)Z .line 3 :cond_0 iget-wide v3, p0, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->c:J const-wide v5, 0x7fffffffffffffffL cmp-long v1, v3, v5 if-gez v1, :cond_1 const-string v1, "replayExpiration=" invoke-static {v1}, Landroid/support/v4/media/d;->a(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v1 iget-wide v3, p0, Lkotlinx/coroutines/flow/StartedWhileSubscribed;->c:J invoke-virtual {v1, v3, v4}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder; invoke-virtual {v1, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder; invoke-virtual {v1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String; move-result-object v1 invoke-interface {v0, v1}, Ljava/util/List;->add(Ljava/lang/Object;)Z .line 4 :cond_1 invoke-static {v0}, Lkotlin/collections/w;->a(Ljava/util/List;)Ljava/util/List; move-result-object v2 const-string v0, "SharingStarted.WhileSubscribed(" .line 5 invoke-static {v0}, Landroid/support/v4/media/d;->a(Ljava/lang/String;)Ljava/lang/StringBuilder; move-result-object v0 const/4 v3, 0x0 const/4 v4, 0x0 const/4 v5, 0x0 const/4 v6, 0x0 const/4 v7, 0x0 const/4 v8, 0x0 const/16 v9, 0x3f const/4 v10, 0x0 invoke-static/range {v2 .. v10}, Lkotlin/collections/CollectionsKt___CollectionsKt;->Z2(Ljava/lang/Iterable;Ljava/lang/CharSequence;Ljava/lang/CharSequence;Ljava/lang/CharSequence;ILjava/lang/CharSequence;Lej/l;ILjava/lang/Object;)Ljava/lang/String; move-result-object v1 const/16 v2, 0x29 invoke-static {v0, v1, v2}, Lu2/g;->a(Ljava/lang/StringBuilder;Ljava/lang/String;C)Ljava/lang/String; move-result-object v0 return-object v0 .end method