FlowableAutoConnect.smali
.class public final Lio/reactivex/internal/operators/flowable/FlowableAutoConnect;
.super Lio/reactivex/Flowable;
.source "FlowableAutoConnect.java"
# annotations
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Lio/reactivex/Flowable<",
"TT;>;"
}
.end annotation
# instance fields
.field final clients:Ljava/util/concurrent/atomic/AtomicInteger;
.field final connection:Lio/reactivex/functions/Consumer;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/functions/Consumer<",
"-",
"Lio/reactivex/disposables/Disposable;",
">;"
}
.end annotation
.end field
.field final numberOfSubscribers:I
.field final source:Lio/reactivex/flowables/ConnectableFlowable;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lio/reactivex/flowables/ConnectableFlowable<",
"+TT;>;"
}
.end annotation
.end field
# direct methods
.method static constructor <clinit>()V
.registers 1
return-void
.end method
.method public constructor <init>(Lio/reactivex/flowables/ConnectableFlowable;ILio/reactivex/functions/Consumer;)V
.registers 5
.param p2, "numberOfSubscribers" # I
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/flowables/ConnectableFlowable<",
"+TT;>;I",
"Lio/reactivex/functions/Consumer<",
"-",
"Lio/reactivex/disposables/Disposable;",
">;)V"
}
.end annotation
.line 39
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableAutoConnect;, "Lio/reactivex/internal/operators/flowable/FlowableAutoConnect<TT;>;"
.local p1, "source":Lio/reactivex/flowables/ConnectableFlowable;, "Lio/reactivex/flowables/ConnectableFlowable<+TT;>;"
.local p3, "connection":Lio/reactivex/functions/Consumer;, "Lio/reactivex/functions/Consumer<-Lio/reactivex/disposables/Disposable;>;"
invoke-direct {p0}, Lio/reactivex/Flowable;-><init>()V
.line 40
iput-object p1, p0, Lio/reactivex/internal/operators/flowable/FlowableAutoConnect;->source:Lio/reactivex/flowables/ConnectableFlowable;
.line 41
iput p2, p0, Lio/reactivex/internal/operators/flowable/FlowableAutoConnect;->numberOfSubscribers:I
.line 42
iput-object p3, p0, Lio/reactivex/internal/operators/flowable/FlowableAutoConnect;->connection:Lio/reactivex/functions/Consumer;
.line 43
new-instance v0, Ljava/util/concurrent/atomic/AtomicInteger;
invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableAutoConnect;->clients:Ljava/util/concurrent/atomic/AtomicInteger;
.line 44
return-void
.end method
# virtual methods
.method public subscribeActual(Lorg/reactivestreams/Subscriber;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lorg/reactivestreams/Subscriber<",
"-TT;>;)V"
}
.end annotation
.line 48
.local p0, "this":Lio/reactivex/internal/operators/flowable/FlowableAutoConnect;, "Lio/reactivex/internal/operators/flowable/FlowableAutoConnect<TT;>;"
.local p1, "child":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableAutoConnect;->source:Lio/reactivex/flowables/ConnectableFlowable;
invoke-virtual {v0, p1}, Lio/reactivex/flowables/ConnectableFlowable;->subscribe(Lorg/reactivestreams/Subscriber;)V
.line 49
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableAutoConnect;->clients:Ljava/util/concurrent/atomic/AtomicInteger;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicInteger;->incrementAndGet()I
move-result v0
iget v1, p0, Lio/reactivex/internal/operators/flowable/FlowableAutoConnect;->numberOfSubscribers:I
if-ne v0, v1, :cond_16
.line 50
iget-object v0, p0, Lio/reactivex/internal/operators/flowable/FlowableAutoConnect;->source:Lio/reactivex/flowables/ConnectableFlowable;
iget-object v1, p0, Lio/reactivex/internal/operators/flowable/FlowableAutoConnect;->connection:Lio/reactivex/functions/Consumer;
invoke-virtual {v0, v1}, Lio/reactivex/flowables/ConnectableFlowable;->connect(Lio/reactivex/functions/Consumer;)V
.line 52
:cond_16
return-void
.end method