.class public final Lkotlinx/coroutines/flow/DistinctFlowImpl; .super Ljava/lang/Object; .source "Distinct.kt" # interfaces .implements Lkotlinx/coroutines/flow/f; # annotations .annotation system Ldalvik/annotation/Signature; value = { "", "Ljava/lang/Object;", "Lkotlinx/coroutines/flow/f<", "TT;>;" } .end annotation .annotation system Ldalvik/annotation/SourceDebugExtension; value = "SMAP\nDistinct.kt\nKotlin\n*S Kotlin\n*F\n+ 1 Distinct.kt\nkotlinx/coroutines/flow/DistinctFlowImpl\n+ 2 Collect.kt\nkotlinx/coroutines/flow/FlowKt__CollectKt\n*L\n1#1,86:1\n72#2,3:87\n*E\n*S KotlinDebug\n*F\n+ 1 Distinct.kt\nkotlinx/coroutines/flow/DistinctFlowImpl\n*L\n77#1,3:87\n*E\n" .end annotation .annotation runtime Lkotlin/Metadata; bv = {} d1 = { "\u00006\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0005\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0010\u000b\n\u0002\u0008\u0004\u0008\u0002\u0018\u0000*\u0004\u0008\u0000\u0010\u00012\u0008\u0012\u0004\u0012\u00028\u00000\u0002Bg\u0012\u000c\u0010\n\u001a\u0008\u0012\u0004\u0012\u00028\u00000\u0002\u0012\u0014\u0010\r\u001a\u0010\u0012\u0004\u0012\u00028\u0000\u0012\u0006\u0012\u0004\u0018\u00010\u000c0\u000b\u0012:\u0010\u0014\u001a6\u0012\u0015\u0012\u0013\u0018\u00010\u000c\u00a2\u0006\u000c\u0008\u000f\u0012\u0008\u0008\u0010\u0012\u0004\u0008\u0008(\u0011\u0012\u0015\u0012\u0013\u0018\u00010\u000c\u00a2\u0006\u000c\u0008\u000f\u0012\u0008\u0008\u0010\u0012\u0004\u0008\u0008(\u0012\u0012\u0004\u0012\u00020\u00130\u000e\u00a2\u0006\u0004\u0008\u0015\u0010\u0016J!\u0010\u0006\u001a\u00020\u00052\u000c\u0010\u0004\u001a\u0008\u0012\u0004\u0012\u00028\u00000\u0003H\u0097@\u00f8\u0001\u0000\u00a2\u0006\u0004\u0008\u0006\u0010\u0007R\u001a\u0010\n\u001a\u0008\u0012\u0004\u0012\u00028\u00000\u00028\u0002X\u0082\u0004\u00a2\u0006\u0006\n\u0004\u0008\u0008\u0010\t\u0082\u0002\u0004\n\u0002\u0008\u0019\u00a8\u0006\u0017" } d2 = { "Lkotlinx/coroutines/flow/DistinctFlowImpl;", "T", "Lkotlinx/coroutines/flow/f;", "Lkotlinx/coroutines/flow/g;", "collector", "Lkotlin/d1;", "e", "(Lkotlinx/coroutines/flow/g;Lkotlin/coroutines/c;)Ljava/lang/Object;", "a", "Lkotlinx/coroutines/flow/f;", "upstream", "Lkotlin/Function1;", "", "keySelector", "Lkotlin/Function2;", "Lkotlin/ParameterName;", "name", "old", "new", "", "areEquivalent", "", "(Lkotlinx/coroutines/flow/f;Lej/l;Lej/p;)V", "kotlinx-coroutines-core" } k = 0x1 mv = { 0x1, 0x4, 0x0 } .end annotation # instance fields .field public final a:Lkotlinx/coroutines/flow/f; .annotation system Ldalvik/annotation/Signature; value = { "Lkotlinx/coroutines/flow/f<", "TT;>;" } .end annotation .end field .field public final b:Lej/l; .annotation system Ldalvik/annotation/Signature; value = { "Lej/l<", "TT;", "Ljava/lang/Object;", ">;" } .end annotation .annotation build Lkotlin/jvm/JvmField; .end annotation .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end field .field public final c:Lej/p; .annotation system Ldalvik/annotation/Signature; value = { "Lej/p<", "Ljava/lang/Object;", "Ljava/lang/Object;", "Ljava/lang/Boolean;", ">;" } .end annotation .annotation build Lkotlin/jvm/JvmField; .end annotation .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end field # direct methods .method public constructor (Lkotlinx/coroutines/flow/f;Lej/l;Lej/p;)V .locals 0 .param p1 # Lkotlinx/coroutines/flow/f; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .param p2 # Lej/l; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .param p3 # Lej/p; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkotlinx/coroutines/flow/f<", "+TT;>;", "Lej/l<", "-TT;+", "Ljava/lang/Object;", ">;", "Lej/p<", "Ljava/lang/Object;", "Ljava/lang/Object;", "Ljava/lang/Boolean;", ">;)V" } .end annotation .line 1 invoke-direct {p0}, Ljava/lang/Object;->()V iput-object p1, p0, Lkotlinx/coroutines/flow/DistinctFlowImpl;->a:Lkotlinx/coroutines/flow/f; iput-object p2, p0, Lkotlinx/coroutines/flow/DistinctFlowImpl;->b:Lej/l; iput-object p3, p0, Lkotlinx/coroutines/flow/DistinctFlowImpl;->c:Lej/p; return-void .end method # virtual methods .method public e(Lkotlinx/coroutines/flow/g;Lkotlin/coroutines/c;)Ljava/lang/Object; .locals 3 .param p1 # Lkotlinx/coroutines/flow/g; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .param p2 # Lkotlin/coroutines/c; .annotation build Lorg/jetbrains/annotations/NotNull; .end annotation .end param .annotation system Ldalvik/annotation/Signature; value = { "(", "Lkotlinx/coroutines/flow/g<", "-TT;>;", "Lkotlin/coroutines/c<", "-", "Lkotlin/d1;", ">;)", "Ljava/lang/Object;" } .end annotation .annotation build Lkotlinx/coroutines/InternalCoroutinesApi; .end annotation .annotation build Lorg/jetbrains/annotations/Nullable; .end annotation .line 1 new-instance v0, Lkotlin/jvm/internal/Ref$ObjectRef; invoke-direct {v0}, Lkotlin/jvm/internal/Ref$ObjectRef;->()V sget-object v1, Lkotlinx/coroutines/flow/internal/n;->a:Lkotlinx/coroutines/internal/i0; iput-object v1, v0, Lkotlin/jvm/internal/Ref$ObjectRef;->element:Ljava/lang/Object; .line 2 iget-object v1, p0, Lkotlinx/coroutines/flow/DistinctFlowImpl;->a:Lkotlinx/coroutines/flow/f; .line 3 new-instance v2, Lkotlinx/coroutines/flow/DistinctFlowImpl$collect$$inlined$collect$1; invoke-direct {v2, p0, v0, p1}, Lkotlinx/coroutines/flow/DistinctFlowImpl$collect$$inlined$collect$1;->(Lkotlinx/coroutines/flow/DistinctFlowImpl;Lkotlin/jvm/internal/Ref$ObjectRef;Lkotlinx/coroutines/flow/g;)V invoke-interface {v1, v2, p2}, Lkotlinx/coroutines/flow/f;->e(Lkotlinx/coroutines/flow/g;Lkotlin/coroutines/c;)Ljava/lang/Object; move-result-object p1 invoke-static {}, Lvi/b;->h()Ljava/lang/Object; move-result-object p2 if-ne p1, p2, :cond_0 return-object p1 .line 4 :cond_0 sget-object p1, Lkotlin/d1;->a:Lkotlin/d1; return-object p1 .end method