MaybeConcatArray$ConcatMaybeObserver.smali
.class final Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;
.super Ljava/util/concurrent/atomic/AtomicInteger;
.source "MaybeConcatArray.java"
# interfaces
.implements Lio/reactivex/MaybeObserver;
.implements Lorg/reactivestreams/Subscription;
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lio/reactivex/internal/operators/maybe/MaybeConcatArray;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "ConcatMaybeObserver"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Ljava/util/concurrent/atomic/AtomicInteger;",
"Lio/reactivex/MaybeObserver<",
"TT;>;",
"Lorg/reactivestreams/Subscription;"
}
.end annotation
# static fields
.field private static final serialVersionUID:J = 0x30dc8174e7c3966aL
# instance fields
.field final actual:Lorg/reactivestreams/Subscriber;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lorg/reactivestreams/Subscriber<",
"-TT;>;"
}
.end annotation
.end field
.field final current:Ljava/util/concurrent/atomic/AtomicReference;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReference<",
"Ljava/lang/Object;",
">;"
}
.end annotation
.end field
.field final disposables:Lio/reactivex/internal/disposables/SequentialDisposable;
.field index:I
.field produced:J
.field final requested:Ljava/util/concurrent/atomic/AtomicLong;
.field final sources:[Lio/reactivex/MaybeSource;
.annotation system Ldalvik/annotation/Signature;
value = {
"[",
"Lio/reactivex/MaybeSource<",
"+TT;>;"
}
.end annotation
.end field
# direct methods
.method static constructor <clinit>()V
.registers 1
return-void
.end method
.method constructor <init>(Lorg/reactivestreams/Subscriber;[Lio/reactivex/MaybeSource;)V
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lorg/reactivestreams/Subscriber<",
"-TT;>;[",
"Lio/reactivex/MaybeSource<",
"+TT;>;)V"
}
.end annotation
.line 66
.local p0, "this":Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;, "Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver<TT;>;"
.local p1, "actual":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TT;>;"
.local p2, "sources":[Lio/reactivex/MaybeSource;, "[Lio/reactivex/MaybeSource<+TT;>;"
invoke-direct {p0}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>()V
.line 67
iput-object p1, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->actual:Lorg/reactivestreams/Subscriber;
.line 68
iput-object p2, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->sources:[Lio/reactivex/MaybeSource;
.line 69
new-instance v0, Ljava/util/concurrent/atomic/AtomicLong;
invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicLong;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->requested:Ljava/util/concurrent/atomic/AtomicLong;
.line 70
new-instance v0, Lio/reactivex/internal/disposables/SequentialDisposable;
invoke-direct {v0}, Lio/reactivex/internal/disposables/SequentialDisposable;-><init>()V
iput-object v0, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->disposables:Lio/reactivex/internal/disposables/SequentialDisposable;
.line 71
new-instance v0, Ljava/util/concurrent/atomic/AtomicReference;
sget-object v1, Lio/reactivex/internal/util/NotificationLite;->COMPLETE:Lio/reactivex/internal/util/NotificationLite;
invoke-direct {v0, v1}, Ljava/util/concurrent/atomic/AtomicReference;-><init>(Ljava/lang/Object;)V
iput-object v0, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->current:Ljava/util/concurrent/atomic/AtomicReference;
.line 72
return-void
.end method
# virtual methods
.method public cancel()V
.registers 2
.line 84
.local p0, "this":Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;, "Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver<TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->disposables:Lio/reactivex/internal/disposables/SequentialDisposable;
invoke-virtual {v0}, Lio/reactivex/internal/disposables/SequentialDisposable;->dispose()V
.line 85
return-void
.end method
.method drain()V
.registers 11
.line 111
.local p0, "this":Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;, "Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver<TT;>;"
invoke-virtual {p0}, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->getAndIncrement()I
move-result v0
if-eqz v0, :cond_7
.line 112
return-void
.line 115
:cond_7
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->current:Ljava/util/concurrent/atomic/AtomicReference;
.line 116
.local v0, "c":Ljava/util/concurrent/atomic/AtomicReference;, "Ljava/util/concurrent/atomic/AtomicReference<Ljava/lang/Object;>;"
iget-object v1, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->actual:Lorg/reactivestreams/Subscriber;
.line 117
.local v1, "a":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TT;>;"
iget-object v2, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->disposables:Lio/reactivex/internal/disposables/SequentialDisposable;
.line 120
.local v2, "cancelled":Lio/reactivex/disposables/Disposable;
:goto_d
invoke-interface {v2}, Lio/reactivex/disposables/Disposable;->isDisposed()Z
move-result v3
const/4 v4, 0x0
if-eqz v3, :cond_18
.line 121
invoke-virtual {v0, v4}, Ljava/util/concurrent/atomic/AtomicReference;->lazySet(Ljava/lang/Object;)V
.line 122
return-void
.line 125
:cond_18
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v3
.line 127
.local v3, "o":Ljava/lang/Object;
if-eqz v3, :cond_5e
.line 129
sget-object v5, Lio/reactivex/internal/util/NotificationLite;->COMPLETE:Lio/reactivex/internal/util/NotificationLite;
if-eq v3, v5, :cond_3d
.line 130
iget-wide v5, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->produced:J
.line 131
.local v5, "p":J
iget-object v7, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->requested:Ljava/util/concurrent/atomic/AtomicLong;
invoke-virtual {v7}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v7
cmp-long v9, v5, v7
if-eqz v9, :cond_3b
.line 132
const-wide/16 v7, 0x1
add-long/2addr v7, v5
iput-wide v7, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->produced:J
.line 133
invoke-virtual {v0, v4}, Ljava/util/concurrent/atomic/AtomicReference;->lazySet(Ljava/lang/Object;)V
.line 134
const/4 v4, 0x1
.line 136
.local v4, "goNextSource":Z
invoke-interface {v1, v3}, Lorg/reactivestreams/Subscriber;->onNext(Ljava/lang/Object;)V
goto :goto_3c
.line 138
.end local v4 # "goNextSource":Z
:cond_3b
const/4 v4, 0x0
.line 140
.end local v5 # "p":J
.restart local v4 # "goNextSource":Z
:goto_3c
goto :goto_42
.line 141
.end local v4 # "goNextSource":Z
:cond_3d
const/4 v5, 0x1
.line 142
.local v5, "goNextSource":Z
invoke-virtual {v0, v4}, Ljava/util/concurrent/atomic/AtomicReference;->lazySet(Ljava/lang/Object;)V
move v4, v5
.line 145
.end local v5 # "goNextSource":Z
.restart local v4 # "goNextSource":Z
:goto_42
if-eqz v4, :cond_5e
invoke-interface {v2}, Lio/reactivex/disposables/Disposable;->isDisposed()Z
move-result v5
if-nez v5, :cond_5e
.line 146
iget v5, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->index:I
.line 147
.local v5, "i":I
iget-object v6, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->sources:[Lio/reactivex/MaybeSource;
array-length v7, v6
if-ne v5, v7, :cond_55
.line 148
invoke-interface {v1}, Lorg/reactivestreams/Subscriber;->onComplete()V
.line 149
return-void
.line 151
:cond_55
add-int/lit8 v7, v5, 0x1
iput v7, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->index:I
.line 153
aget-object v6, v6, v5
invoke-interface {v6, p0}, Lio/reactivex/MaybeSource;->subscribe(Lio/reactivex/MaybeObserver;)V
.line 157
.end local v4 # "goNextSource":Z
.end local v5 # "i":I
:cond_5e
invoke-virtual {p0}, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->decrementAndGet()I
move-result v4
if-nez v4, :cond_66
.line 158
nop
.line 161
.end local v3 # "o":Ljava/lang/Object;
return-void
.line 160
:cond_66
goto :goto_d
.end method
.method public onComplete()V
.registers 3
.line 105
.local p0, "this":Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;, "Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver<TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->current:Ljava/util/concurrent/atomic/AtomicReference;
sget-object v1, Lio/reactivex/internal/util/NotificationLite;->COMPLETE:Lio/reactivex/internal/util/NotificationLite;
invoke-virtual {v0, v1}, Ljava/util/concurrent/atomic/AtomicReference;->lazySet(Ljava/lang/Object;)V
.line 106
invoke-virtual {p0}, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->drain()V
.line 107
return-void
.end method
.method public onError(Ljava/lang/Throwable;)V
.registers 3
.param p1, "e" # Ljava/lang/Throwable;
.line 100
.local p0, "this":Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;, "Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver<TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->actual:Lorg/reactivestreams/Subscriber;
invoke-interface {v0, p1}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
.line 101
return-void
.end method
.method public onSubscribe(Lio/reactivex/disposables/Disposable;)V
.registers 3
.param p1, "d" # Lio/reactivex/disposables/Disposable;
.line 89
.local p0, "this":Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;, "Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver<TT;>;"
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->disposables:Lio/reactivex/internal/disposables/SequentialDisposable;
invoke-virtual {v0, p1}, Lio/reactivex/internal/disposables/SequentialDisposable;->replace(Lio/reactivex/disposables/Disposable;)Z
.line 90
return-void
.end method
.method public onSuccess(Ljava/lang/Object;)V
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 94
.local p0, "this":Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;, "Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver<TT;>;"
.local p1, "value":Ljava/lang/Object;, "TT;"
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->current:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0, p1}, Ljava/util/concurrent/atomic/AtomicReference;->lazySet(Ljava/lang/Object;)V
.line 95
invoke-virtual {p0}, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->drain()V
.line 96
return-void
.end method
.method public request(J)V
.registers 4
.param p1, "n" # J
.line 76
.local p0, "this":Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;, "Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver<TT;>;"
invoke-static {p1, p2}, Lio/reactivex/internal/subscriptions/SubscriptionHelper;->validate(J)Z
move-result v0
if-eqz v0, :cond_e
.line 77
iget-object v0, p0, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->requested:Ljava/util/concurrent/atomic/AtomicLong;
invoke-static {v0, p1, p2}, Lio/reactivex/internal/util/BackpressureHelper;->add(Ljava/util/concurrent/atomic/AtomicLong;J)J
.line 78
invoke-virtual {p0}, Lio/reactivex/internal/operators/maybe/MaybeConcatArray$ConcatMaybeObserver;->drain()V
.line 80
:cond_e
return-void
.end method