OperatorMerge$MergeSubscriber.smali
.class final Lrx/internal/operators/OperatorMerge$MergeSubscriber;
.super Lrx/Subscriber;
.source "OperatorMerge.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingClass;
value = Lrx/internal/operators/OperatorMerge;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x18
name = "MergeSubscriber"
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Lrx/Subscriber<",
"Lrx/Observable<",
"+TT;>;>;"
}
.end annotation
# static fields
.field static final EMPTY:[Lrx/internal/operators/OperatorMerge$InnerSubscriber;
.annotation system Ldalvik/annotation/Signature;
value = {
"[",
"Lrx/internal/operators/OperatorMerge$InnerSubscriber<",
"*>;"
}
.end annotation
.end field
# instance fields
.field final child:Lrx/Subscriber;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/Subscriber<",
"-TT;>;"
}
.end annotation
.end field
.field final delayErrors:Z
.field volatile done:Z
.field emitting:Z
.field volatile errors:Ljava/util/concurrent/ConcurrentLinkedQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/ConcurrentLinkedQueue<",
"Ljava/lang/Throwable;",
">;"
}
.end annotation
.end field
.field final innerGuard:Ljava/lang/Object;
.field volatile innerSubscribers:[Lrx/internal/operators/OperatorMerge$InnerSubscriber;
.annotation system Ldalvik/annotation/Signature;
value = {
"[",
"Lrx/internal/operators/OperatorMerge$InnerSubscriber<",
"*>;"
}
.end annotation
.end field
.field lastId:J
.field lastIndex:I
.field final maxConcurrent:I
.field missed:Z
.field producer:Lrx/internal/operators/OperatorMerge$MergeProducer;
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/internal/operators/OperatorMerge$MergeProducer<",
"TT;>;"
}
.end annotation
.end field
.field volatile queue:Ljava/util/Queue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/Queue<",
"Ljava/lang/Object;",
">;"
}
.end annotation
.end field
.field scalarEmissionCount:I
.field final scalarEmissionLimit:I
.field volatile subscriptions:Lrx/subscriptions/CompositeSubscription;
.field uniqueId:J
# direct methods
.method static constructor <clinit>()V
.registers 1
const/4 v0, 0x0
.line 1
new-array v0, v0, [Lrx/internal/operators/OperatorMerge$InnerSubscriber;
sput-object v0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->EMPTY:[Lrx/internal/operators/OperatorMerge$InnerSubscriber;
return-void
.end method
.method public constructor <init>(Lrx/Subscriber;ZI)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/Subscriber<",
"-TT;>;ZI)V"
}
.end annotation
.line 1
invoke-direct {p0}, Lrx/Subscriber;-><init>()V
.line 2
iput-object p1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->child:Lrx/Subscriber;
.line 3
iput-boolean p2, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->delayErrors:Z
.line 4
iput p3, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->maxConcurrent:I
.line 5
new-instance p1, Ljava/lang/Object;
invoke-direct {p1}, Ljava/lang/Object;-><init>()V
iput-object p1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->innerGuard:Ljava/lang/Object;
.line 6
sget-object p1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->EMPTY:[Lrx/internal/operators/OperatorMerge$InnerSubscriber;
iput-object p1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->innerSubscribers:[Lrx/internal/operators/OperatorMerge$InnerSubscriber;
const p1, 0x7fffffff
if-ne p3, p1, :cond_24
.line 7
iput p1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->scalarEmissionLimit:I
const-wide p1, 0x7fffffffffffffffL
.line 8
invoke-virtual {p0, p1, p2}, Lrx/Subscriber;->request(J)V
goto :goto_31
:cond_24
shr-int/lit8 p1, p3, 0x1
const/4 p2, 0x1
.line 9
invoke-static {p2, p1}, Ljava/lang/Math;->max(II)I
move-result p1
iput p1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->scalarEmissionLimit:I
int-to-long p1, p3
.line 10
invoke-virtual {p0, p1, p2}, Lrx/Subscriber;->request(J)V
:goto_31
return-void
.end method
.method private reportError()V
.registers 4
.line 1
new-instance v0, Ljava/util/ArrayList;
iget-object v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->errors:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {v0, v1}, Ljava/util/ArrayList;-><init>(Ljava/util/Collection;)V
.line 2
invoke-interface {v0}, Ljava/util/List;->size()I
move-result v1
const/4 v2, 0x1
if-ne v1, v2, :cond_1b
.line 3
iget-object v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->child:Lrx/Subscriber;
const/4 v2, 0x0
invoke-interface {v0, v2}, Ljava/util/List;->get(I)Ljava/lang/Object;
move-result-object v0
check-cast v0, Ljava/lang/Throwable;
invoke-interface {v1, v0}, Lrx/Observer;->onError(Ljava/lang/Throwable;)V
goto :goto_25
.line 4
:cond_1b
iget-object v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->child:Lrx/Subscriber;
new-instance v2, Lrx/exceptions/CompositeException;
invoke-direct {v2, v0}, Lrx/exceptions/CompositeException;-><init>(Ljava/util/Collection;)V
invoke-interface {v1, v2}, Lrx/Observer;->onError(Ljava/lang/Throwable;)V
:goto_25
return-void
.end method
# virtual methods
.method addInner(Lrx/internal/operators/OperatorMerge$InnerSubscriber;)V
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/internal/operators/OperatorMerge$InnerSubscriber<",
"TT;>;)V"
}
.end annotation
.line 1
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->getOrCreateComposite()Lrx/subscriptions/CompositeSubscription;
move-result-object v0
invoke-virtual {v0, p1}, Lrx/subscriptions/CompositeSubscription;->add(Lrx/Subscription;)V
.line 2
iget-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->innerGuard:Ljava/lang/Object;
monitor-enter v0
.line 3
:try_start_a
iget-object v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->innerSubscribers:[Lrx/internal/operators/OperatorMerge$InnerSubscriber;
.line 4
array-length v2, v1
add-int/lit8 v3, v2, 0x1
.line 5
new-array v3, v3, [Lrx/internal/operators/OperatorMerge$InnerSubscriber;
const/4 v4, 0x0
.line 6
invoke-static {v1, v4, v3, v4, v2}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
.line 7
aput-object p1, v3, v2
.line 8
iput-object v3, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->innerSubscribers:[Lrx/internal/operators/OperatorMerge$InnerSubscriber;
.line 9
monitor-exit v0
return-void
:catchall_1b
move-exception p1
monitor-exit v0
:try_end_1d
.catchall {:try_start_a .. :try_end_1d} :catchall_1b
throw p1
.end method
.method checkTerminate()Z
.registers 4
.line 1
iget-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->child:Lrx/Subscriber;
invoke-virtual {v0}, Lrx/Subscriber;->isUnsubscribed()Z
move-result v0
const/4 v1, 0x1
if-eqz v0, :cond_a
return v1
.line 2
:cond_a
iget-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->errors:Ljava/util/concurrent/ConcurrentLinkedQueue;
.line 3
iget-boolean v2, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->delayErrors:Z
if-nez v2, :cond_24
if-eqz v0, :cond_24
invoke-interface {v0}, Ljava/util/Queue;->isEmpty()Z
move-result v0
if-nez v0, :cond_24
.line 4
:try_start_18
invoke-direct {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->reportError()V
:try_end_1b
.catchall {:try_start_18 .. :try_end_1b} :catchall_1f
.line 5
invoke-virtual {p0}, Lrx/Subscriber;->unsubscribe()V
return v1
:catchall_1f
move-exception v0
invoke-virtual {p0}, Lrx/Subscriber;->unsubscribe()V
throw v0
:cond_24
const/4 v0, 0x0
return v0
.end method
.method emit()V
.registers 3
.line 1
monitor-enter p0
.line 2
:try_start_1
iget-boolean v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitting:Z
const/4 v1, 0x1
if-eqz v0, :cond_a
.line 3
iput-boolean v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->missed:Z
.line 4
monitor-exit p0
return-void
.line 5
:cond_a
iput-boolean v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitting:Z
.line 6
monitor-exit p0
:try_end_d
.catchall {:try_start_1 .. :try_end_d} :catchall_11
.line 7
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitLoop()V
return-void
:catchall_11
move-exception v0
.line 8
:try_start_12
monitor-exit p0
:try_end_13
.catchall {:try_start_12 .. :try_end_13} :catchall_11
throw v0
.end method
.method emitEmpty()V
.registers 3
.line 1
iget v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->scalarEmissionCount:I
add-int/lit8 v0, v0, 0x1
.line 2
iget v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->scalarEmissionLimit:I
if-ne v0, v1, :cond_10
const/4 v1, 0x0
.line 3
iput v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->scalarEmissionCount:I
int-to-long v0, v0
.line 4
invoke-virtual {p0, v0, v1}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->requestMore(J)V
goto :goto_12
.line 5
:cond_10
iput v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->scalarEmissionCount:I
:goto_12
return-void
.end method
.method emitLoop()V
.registers 23
move-object/from16 v1, p0
.line 1
:try_start_2
iget-object v4, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->child:Lrx/Subscriber;
.line 2
:goto_4
invoke-virtual/range {p0 .. p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->checkTerminate()Z
move-result v0
if-eqz v0, :cond_b
return-void
.line 3
:cond_b
iget-object v5, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->queue:Ljava/util/Queue;
.line 4
iget-object v0, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->producer:Lrx/internal/operators/OperatorMerge$MergeProducer;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v6
const-wide v8, 0x7fffffffffffffffL
cmp-long v0, v6, v8
if-nez v0, :cond_1e
const/4 v10, 0x1
goto :goto_1f
:cond_1e
const/4 v10, 0x0
:goto_1f
const-wide/16 v11, 0x1
const-wide/16 v14, 0x0
if-eqz v5, :cond_93
const/4 v0, 0x0
:goto_26
move/from16 v16, v0
const/4 v0, 0x0
const/4 v2, 0x0
:goto_2a
cmp-long v17, v6, v14
if-lez v17, :cond_74
.line 5
invoke-interface {v5}, Ljava/util/Queue;->poll()Ljava/lang/Object;
move-result-object v17
.line 6
invoke-virtual/range {p0 .. p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->checkTerminate()Z
move-result v0
if-eqz v0, :cond_39
return-void
:cond_39
if-nez v17, :cond_3e
move-object/from16 v0, v17
goto :goto_74
.line 7
:cond_3e
invoke-static/range {v17 .. v17}, Lrx/internal/operators/NotificationLite;->getValue(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
:try_end_42
.catchall {:try_start_2 .. :try_end_42} :catchall_1cc
.line 8
:try_start_42
invoke-interface {v4, v0}, Lrx/Observer;->onNext(Ljava/lang/Object;)V
:try_end_45
.catch Ljava/lang/Throwable; {:try_start_42 .. :try_end_45} :catch_46
.catchall {:try_start_42 .. :try_end_45} :catchall_1cc
goto :goto_67
:catch_46
move-exception v0
move-object/from16 v18, v0
.line 9
:try_start_49
iget-boolean v0, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->delayErrors:Z
if-nez v0, :cond_5e
.line 10
invoke-static/range {v18 .. v18}, Lrx/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V
:try_end_50
.catchall {:try_start_49 .. :try_end_50} :catchall_1cc
.line 11
:try_start_50
invoke-virtual/range {p0 .. p0}, Lrx/Subscriber;->unsubscribe()V
move-object/from16 v2, v18
.line 12
invoke-interface {v4, v2}, Lrx/Observer;->onError(Ljava/lang/Throwable;)V
:try_end_58
.catchall {:try_start_50 .. :try_end_58} :catchall_59
return-void
:catchall_59
move-exception v0
const/16 v21, 0x1
goto/16 :goto_1cf
:cond_5e
move-object/from16 v8, v18
.line 13
:try_start_60
invoke-virtual/range {p0 .. p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->getOrCreateErrorQueue()Ljava/util/Queue;
move-result-object v0
invoke-interface {v0, v8}, Ljava/util/Queue;->offer(Ljava/lang/Object;)Z
:goto_67
add-int/lit8 v16, v16, 0x1
add-int/lit8 v2, v2, 0x1
sub-long/2addr v6, v11
move-object/from16 v0, v17
const-wide v8, 0x7fffffffffffffffL
goto :goto_2a
:cond_74
:goto_74
if-lez v2, :cond_84
if-eqz v10, :cond_7e
const-wide v6, 0x7fffffffffffffffL
goto :goto_84
.line 14
:cond_7e
iget-object v6, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->producer:Lrx/internal/operators/OperatorMerge$MergeProducer;
invoke-virtual {v6, v2}, Lrx/internal/operators/OperatorMerge$MergeProducer;->produced(I)J
move-result-wide v6
:cond_84
:goto_84
cmp-long v2, v6, v14
if-eqz v2, :cond_95
if-nez v0, :cond_8b
goto :goto_95
:cond_8b
move/from16 v0, v16
const-wide v8, 0x7fffffffffffffffL
goto :goto_26
:cond_93
const/16 v16, 0x0
.line 15
:cond_95
:goto_95
iget-boolean v0, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->done:Z
.line 16
iget-object v2, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->queue:Ljava/util/Queue;
.line 17
iget-object v5, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->innerSubscribers:[Lrx/internal/operators/OperatorMerge$InnerSubscriber;
.line 18
array-length v8, v5
if-eqz v0, :cond_bb
if-eqz v2, :cond_a6
.line 19
invoke-interface {v2}, Ljava/util/Queue;->isEmpty()Z
move-result v0
if-eqz v0, :cond_bb
:cond_a6
if-nez v8, :cond_bb
.line 20
iget-object v0, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->errors:Ljava/util/concurrent/ConcurrentLinkedQueue;
if-eqz v0, :cond_b7
.line 21
invoke-interface {v0}, Ljava/util/Queue;->isEmpty()Z
move-result v0
if-eqz v0, :cond_b3
goto :goto_b7
.line 22
:cond_b3
invoke-direct/range {p0 .. p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->reportError()V
goto :goto_ba
.line 23
:cond_b7
:goto_b7
invoke-interface {v4}, Lrx/Observer;->onCompleted()V
:goto_ba
return-void
:cond_bb
if-lez v8, :cond_1a1
.line 24
iget-wide v11, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->lastId:J
.line 25
iget v0, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->lastIndex:I
if-le v8, v0, :cond_ce
.line 26
aget-object v2, v5, v0
move-object/from16 v17, v4
iget-wide v3, v2, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->id:J
cmp-long v2, v3, v11
if-eqz v2, :cond_f3
goto :goto_d0
:cond_ce
move-object/from16 v17, v4
:goto_d0
if-gt v8, v0, :cond_d3
const/4 v0, 0x0
:cond_d3
move v2, v0
const/4 v0, 0x0
:goto_d5
if-ge v0, v8, :cond_ea
.line 27
aget-object v3, v5, v2
iget-wide v3, v3, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->id:J
cmp-long v21, v3, v11
if-nez v21, :cond_e0
goto :goto_ea
:cond_e0
add-int/lit8 v3, v2, 0x1
if-ne v3, v8, :cond_e6
const/4 v2, 0x0
goto :goto_e7
:cond_e6
move v2, v3
:goto_e7
add-int/lit8 v0, v0, 0x1
goto :goto_d5
.line 28
:cond_ea
:goto_ea
iput v2, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->lastIndex:I
.line 29
aget-object v0, v5, v2
iget-wide v3, v0, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->id:J
iput-wide v3, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->lastId:J
move v0, v2
:cond_f3
move v2, v0
const/4 v0, 0x0
const/4 v3, 0x0
:goto_f6
if-ge v0, v8, :cond_194
.line 30
invoke-virtual/range {p0 .. p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->checkTerminate()Z
move-result v4
if-eqz v4, :cond_ff
return-void
.line 31
:cond_ff
aget-object v4, v5, v2
const/4 v11, 0x0
:goto_102
move-object v12, v11
const/4 v11, 0x0
:goto_104
cmp-long v21, v6, v14
if-lez v21, :cond_11a
.line 32
invoke-virtual/range {p0 .. p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->checkTerminate()Z
move-result v21
if-eqz v21, :cond_10f
return-void
.line 33
:cond_10f
iget-object v9, v4, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->queue:Lrx/internal/util/RxRingBuffer;
if-nez v9, :cond_114
goto :goto_11a
.line 34
:cond_114
invoke-virtual {v9}, Lrx/internal/util/RxRingBuffer;->poll()Ljava/lang/Object;
move-result-object v12
if-nez v12, :cond_11f
:cond_11a
:goto_11a
move-object/from16 v13, v17
const-wide/16 v19, 0x1
goto :goto_143
.line 35
:cond_11f
invoke-static {v12}, Lrx/internal/operators/NotificationLite;->getValue(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v9
:try_end_123
.catchall {:try_start_60 .. :try_end_123} :catchall_1cc
move-object/from16 v13, v17
.line 36
:try_start_125
invoke-interface {v13, v9}, Lrx/Observer;->onNext(Ljava/lang/Object;)V
:try_end_128
.catch Ljava/lang/Throwable; {:try_start_125 .. :try_end_128} :catch_131
.catchall {:try_start_125 .. :try_end_128} :catchall_1cc
const-wide/16 v19, 0x1
sub-long v6, v6, v19
add-int/lit8 v11, v11, 0x1
move-object/from16 v17, v13
goto :goto_104
:catch_131
move-exception v0
move-object v2, v0
.line 37
:try_start_133
invoke-static {v2}, Lrx/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V
:try_end_136
.catchall {:try_start_133 .. :try_end_136} :catchall_59
.line 38
:try_start_136
invoke-interface {v13, v2}, Lrx/Observer;->onError(Ljava/lang/Throwable;)V
:try_end_139
.catchall {:try_start_136 .. :try_end_139} :catchall_13d
.line 39
:try_start_139
invoke-virtual/range {p0 .. p0}, Lrx/Subscriber;->unsubscribe()V
return-void
:catchall_13d
move-exception v0
move-object v2, v0
invoke-virtual/range {p0 .. p0}, Lrx/Subscriber;->unsubscribe()V
throw v2
:try_end_143
.catchall {:try_start_139 .. :try_end_143} :catchall_59
:goto_143
if-lez v11, :cond_159
if-nez v10, :cond_14e
.line 40
:try_start_147
iget-object v6, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->producer:Lrx/internal/operators/OperatorMerge$MergeProducer;
invoke-virtual {v6, v11}, Lrx/internal/operators/OperatorMerge$MergeProducer;->produced(I)J
move-result-wide v6
goto :goto_153
:cond_14e
const-wide v6, 0x7fffffffffffffffL
:goto_153
int-to-long v14, v11
.line 41
invoke-virtual {v4, v14, v15}, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->requestMore(J)V
const-wide/16 v14, 0x0
:cond_159
cmp-long v9, v6, v14
if-eqz v9, :cond_166
if-nez v12, :cond_160
goto :goto_166
:cond_160
move-object v11, v12
move-object/from16 v17, v13
const-wide/16 v14, 0x0
goto :goto_102
.line 42
:cond_166
:goto_166
iget-boolean v9, v4, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->done:Z
.line 43
iget-object v11, v4, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->queue:Lrx/internal/util/RxRingBuffer;
if-eqz v9, :cond_181
if-eqz v11, :cond_174
.line 44
invoke-virtual {v11}, Lrx/internal/util/RxRingBuffer;->isEmpty()Z
move-result v9
if-eqz v9, :cond_181
.line 45
:cond_174
invoke-virtual {v1, v4}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->removeInner(Lrx/internal/operators/OperatorMerge$InnerSubscriber;)V
.line 46
invoke-virtual/range {p0 .. p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->checkTerminate()Z
move-result v3
if-eqz v3, :cond_17e
return-void
:cond_17e
add-int/lit8 v16, v16, 0x1
const/4 v3, 0x1
:cond_181
const-wide/16 v11, 0x0
cmp-long v4, v6, v11
if-nez v4, :cond_188
goto :goto_196
:cond_188
add-int/lit8 v2, v2, 0x1
if-ne v2, v8, :cond_18d
const/4 v2, 0x0
:cond_18d
add-int/lit8 v0, v0, 0x1
move-wide v14, v11
move-object/from16 v17, v13
goto/16 :goto_f6
:cond_194
move-object/from16 v13, v17
.line 47
:goto_196
iput v2, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->lastIndex:I
.line 48
aget-object v0, v5, v2
iget-wide v4, v0, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->id:J
iput-wide v4, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->lastId:J
move/from16 v0, v16
goto :goto_1a5
:cond_1a1
move-object v13, v4
move/from16 v0, v16
const/4 v3, 0x0
:goto_1a5
if-lez v0, :cond_1ab
int-to-long v4, v0
.line 49
invoke-virtual {v1, v4, v5}, Lrx/Subscriber;->request(J)V
:cond_1ab
if-eqz v3, :cond_1b0
:goto_1ad
move-object v4, v13
goto/16 :goto_4
.line 50
:cond_1b0
monitor-enter p0
:try_end_1b1
.catchall {:try_start_147 .. :try_end_1b1} :catchall_1cc
.line 51
:try_start_1b1
iget-boolean v0, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->missed:Z
:try_end_1b3
.catchall {:try_start_1b1 .. :try_end_1b3} :catchall_1c2
if-nez v0, :cond_1bd
const/4 v2, 0x0
.line 52
:try_start_1b6
iput-boolean v2, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitting:Z
.line 53
monitor-exit p0
:try_end_1b9
.catchall {:try_start_1b6 .. :try_end_1b9} :catchall_1ba
return-void
:catchall_1ba
move-exception v0
const/4 v2, 0x1
goto :goto_1c4
:cond_1bd
const/4 v2, 0x0
.line 54
:try_start_1be
iput-boolean v2, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->missed:Z
.line 55
monitor-exit p0
:try_end_1c1
.catchall {:try_start_1be .. :try_end_1c1} :catchall_1c2
goto :goto_1ad
:catchall_1c2
move-exception v0
const/4 v2, 0x0
:goto_1c4
:try_start_1c4
monitor-exit p0
:try_end_1c5
.catchall {:try_start_1c4 .. :try_end_1c5} :catchall_1ca
:try_start_1c5
throw v0
:try_end_1c6
.catchall {:try_start_1c5 .. :try_end_1c6} :catchall_1c6
:catchall_1c6
move-exception v0
move/from16 v21, v2
goto :goto_1cf
:catchall_1ca
move-exception v0
goto :goto_1c4
:catchall_1cc
move-exception v0
const/16 v21, 0x0
:goto_1cf
if-nez v21, :cond_1da
.line 56
monitor-enter p0
const/4 v2, 0x0
.line 57
:try_start_1d3
iput-boolean v2, v1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitting:Z
.line 58
monitor-exit p0
goto :goto_1da
:catchall_1d7
move-exception v0
monitor-exit p0
:try_end_1d9
.catchall {:try_start_1d3 .. :try_end_1d9} :catchall_1d7
throw v0
:cond_1da
:goto_1da
goto :goto_1dc
:goto_1db
throw v0
:goto_1dc
goto :goto_1db
.end method
.method protected emitScalar(Ljava/lang/Object;J)V
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;J)V"
}
.end annotation
const/4 v0, 0x1
const/4 v1, 0x0
.line 20
:try_start_2
iget-object v2, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->child:Lrx/Subscriber;
invoke-interface {v2, p1}, Lrx/Observer;->onNext(Ljava/lang/Object;)V
:try_end_7
.catch Ljava/lang/Throwable; {:try_start_2 .. :try_end_7} :catch_b
.catchall {:try_start_2 .. :try_end_7} :catchall_8
goto :goto_23
:catchall_8
move-exception p1
const/4 v0, 0x0
goto :goto_54
:catch_b
move-exception p1
.line 21
:try_start_c
iget-boolean v2, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->delayErrors:Z
if-nez v2, :cond_1c
.line 22
invoke-static {p1}, Lrx/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V
:try_end_13
.catchall {:try_start_c .. :try_end_13} :catchall_8
.line 23
:try_start_13
invoke-virtual {p0}, Lrx/Subscriber;->unsubscribe()V
.line 24
invoke-virtual {p0, p1}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->onError(Ljava/lang/Throwable;)V
:try_end_19
.catchall {:try_start_13 .. :try_end_19} :catchall_1a
return-void
:catchall_1a
move-exception p1
goto :goto_54
.line 25
:cond_1c
:try_start_1c
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->getOrCreateErrorQueue()Ljava/util/Queue;
move-result-object v2
invoke-interface {v2, p1}, Ljava/util/Queue;->offer(Ljava/lang/Object;)Z
:goto_23
const-wide v2, 0x7fffffffffffffffL
cmp-long p1, p2, v2
if-eqz p1, :cond_31
.line 26
iget-object p1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->producer:Lrx/internal/operators/OperatorMerge$MergeProducer;
invoke-virtual {p1, v0}, Lrx/internal/operators/OperatorMerge$MergeProducer;->produced(I)J
.line 27
:cond_31
iget p1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->scalarEmissionCount:I
add-int/2addr p1, v0
.line 28
iget p2, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->scalarEmissionLimit:I
if-ne p1, p2, :cond_3f
.line 29
iput v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->scalarEmissionCount:I
int-to-long p1, p1
.line 30
invoke-virtual {p0, p1, p2}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->requestMore(J)V
goto :goto_41
.line 31
:cond_3f
iput p1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->scalarEmissionCount:I
.line 32
:goto_41
monitor-enter p0
:try_end_42
.catchall {:try_start_1c .. :try_end_42} :catchall_8
.line 33
:try_start_42
iget-boolean p1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->missed:Z
if-nez p1, :cond_4a
.line 34
iput-boolean v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitting:Z
.line 35
monitor-exit p0
return-void
.line 36
:cond_4a
iput-boolean v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->missed:Z
.line 37
monitor-exit p0
:try_end_4d
.catchall {:try_start_42 .. :try_end_4d} :catchall_51
.line 38
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitLoop()V
return-void
:catchall_51
move-exception p1
.line 39
:try_start_52
monitor-exit p0
:try_end_53
.catchall {:try_start_52 .. :try_end_53} :catchall_51
:try_start_53
throw p1
:try_end_54
.catchall {:try_start_53 .. :try_end_54} :catchall_1a
:goto_54
if-nez v0, :cond_5e
.line 40
monitor-enter p0
.line 41
:try_start_57
iput-boolean v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitting:Z
.line 42
monitor-exit p0
goto :goto_5e
:catchall_5b
move-exception p1
monitor-exit p0
:try_end_5d
.catchall {:try_start_57 .. :try_end_5d} :catchall_5b
throw p1
:cond_5e
:goto_5e
throw p1
.end method
.method protected emitScalar(Lrx/internal/operators/OperatorMerge$InnerSubscriber;Ljava/lang/Object;J)V
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/internal/operators/OperatorMerge$InnerSubscriber<",
"TT;>;TT;J)V"
}
.end annotation
const/4 v0, 0x1
const/4 v1, 0x0
.line 1
:try_start_2
iget-object v2, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->child:Lrx/Subscriber;
invoke-interface {v2, p2}, Lrx/Observer;->onNext(Ljava/lang/Object;)V
:try_end_7
.catch Ljava/lang/Throwable; {:try_start_2 .. :try_end_7} :catch_b
.catchall {:try_start_2 .. :try_end_7} :catchall_8
goto :goto_23
:catchall_8
move-exception p1
const/4 v0, 0x0
goto :goto_49
:catch_b
move-exception p2
.line 2
:try_start_c
iget-boolean v2, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->delayErrors:Z
if-nez v2, :cond_1c
.line 3
invoke-static {p2}, Lrx/exceptions/Exceptions;->throwIfFatal(Ljava/lang/Throwable;)V
:try_end_13
.catchall {:try_start_c .. :try_end_13} :catchall_8
.line 4
:try_start_13
invoke-virtual {p1}, Lrx/Subscriber;->unsubscribe()V
.line 5
invoke-virtual {p1, p2}, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->onError(Ljava/lang/Throwable;)V
:try_end_19
.catchall {:try_start_13 .. :try_end_19} :catchall_1a
return-void
:catchall_1a
move-exception p1
goto :goto_49
.line 6
:cond_1c
:try_start_1c
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->getOrCreateErrorQueue()Ljava/util/Queue;
move-result-object v2
invoke-interface {v2, p2}, Ljava/util/Queue;->offer(Ljava/lang/Object;)Z
:goto_23
const-wide v2, 0x7fffffffffffffffL
cmp-long p2, p3, v2
if-eqz p2, :cond_31
.line 7
iget-object p2, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->producer:Lrx/internal/operators/OperatorMerge$MergeProducer;
invoke-virtual {p2, v0}, Lrx/internal/operators/OperatorMerge$MergeProducer;->produced(I)J
:cond_31
const-wide/16 p2, 0x1
.line 8
invoke-virtual {p1, p2, p3}, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->requestMore(J)V
.line 9
monitor-enter p0
:try_end_37
.catchall {:try_start_1c .. :try_end_37} :catchall_8
.line 10
:try_start_37
iget-boolean p1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->missed:Z
if-nez p1, :cond_3f
.line 11
iput-boolean v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitting:Z
.line 12
monitor-exit p0
return-void
.line 13
:cond_3f
iput-boolean v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->missed:Z
.line 14
monitor-exit p0
:try_end_42
.catchall {:try_start_37 .. :try_end_42} :catchall_46
.line 15
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitLoop()V
return-void
:catchall_46
move-exception p1
.line 16
:try_start_47
monitor-exit p0
:try_end_48
.catchall {:try_start_47 .. :try_end_48} :catchall_46
:try_start_48
throw p1
:try_end_49
.catchall {:try_start_48 .. :try_end_49} :catchall_1a
:goto_49
if-nez v0, :cond_53
.line 17
monitor-enter p0
.line 18
:try_start_4c
iput-boolean v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitting:Z
.line 19
monitor-exit p0
goto :goto_53
:catchall_50
move-exception p1
monitor-exit p0
:try_end_52
.catchall {:try_start_4c .. :try_end_52} :catchall_50
throw p1
:cond_53
:goto_53
throw p1
.end method
.method getOrCreateComposite()Lrx/subscriptions/CompositeSubscription;
.registers 3
.line 1
iget-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->subscriptions:Lrx/subscriptions/CompositeSubscription;
if-nez v0, :cond_1f
const/4 v0, 0x0
.line 2
monitor-enter p0
.line 3
:try_start_6
iget-object v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->subscriptions:Lrx/subscriptions/CompositeSubscription;
if-nez v1, :cond_14
.line 4
new-instance v0, Lrx/subscriptions/CompositeSubscription;
invoke-direct {v0}, Lrx/subscriptions/CompositeSubscription;-><init>()V
.line 5
iput-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->subscriptions:Lrx/subscriptions/CompositeSubscription;
const/4 v1, 0x1
move-object v1, v0
const/4 v0, 0x1
.line 6
:cond_14
monitor-exit p0
:try_end_15
.catchall {:try_start_6 .. :try_end_15} :catchall_1c
if-eqz v0, :cond_1a
.line 7
invoke-virtual {p0, v1}, Lrx/Subscriber;->add(Lrx/Subscription;)V
:cond_1a
move-object v0, v1
goto :goto_1f
:catchall_1c
move-exception v0
.line 8
:try_start_1d
monitor-exit p0
:try_end_1e
.catchall {:try_start_1d .. :try_end_1e} :catchall_1c
throw v0
:cond_1f
:goto_1f
return-object v0
.end method
.method getOrCreateErrorQueue()Ljava/util/Queue;
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"()",
"Ljava/util/Queue<",
"Ljava/lang/Throwable;",
">;"
}
.end annotation
.line 1
iget-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->errors:Ljava/util/concurrent/ConcurrentLinkedQueue;
if-nez v0, :cond_15
.line 2
monitor-enter p0
.line 3
:try_start_5
iget-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->errors:Ljava/util/concurrent/ConcurrentLinkedQueue;
if-nez v0, :cond_10
.line 4
new-instance v0, Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>()V
.line 5
iput-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->errors:Ljava/util/concurrent/ConcurrentLinkedQueue;
.line 6
:cond_10
monitor-exit p0
goto :goto_15
:catchall_12
move-exception v0
monitor-exit p0
:try_end_14
.catchall {:try_start_5 .. :try_end_14} :catchall_12
throw v0
:cond_15
:goto_15
return-object v0
.end method
.method public onCompleted()V
.registers 2
const/4 v0, 0x1
.line 1
iput-boolean v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->done:Z
.line 2
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emit()V
return-void
.end method
.method public onError(Ljava/lang/Throwable;)V
.registers 3
.line 1
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->getOrCreateErrorQueue()Ljava/util/Queue;
move-result-object v0
invoke-interface {v0, p1}, Ljava/util/Queue;->offer(Ljava/lang/Object;)Z
const/4 p1, 0x1
.line 2
iput-boolean p1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->done:Z
.line 3
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emit()V
return-void
.end method
.method public bridge synthetic onNext(Ljava/lang/Object;)V
.registers 2
.line 1
check-cast p1, Lrx/Observable;
invoke-virtual {p0, p1}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->onNext(Lrx/Observable;)V
return-void
.end method
.method public onNext(Lrx/Observable;)V
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/Observable<",
"+TT;>;)V"
}
.end annotation
if-nez p1, :cond_3
return-void
.line 2
:cond_3
invoke-static {}, Lrx/Observable;->empty()Lrx/Observable;
move-result-object v0
if-ne p1, v0, :cond_d
.line 3
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitEmpty()V
goto :goto_30
.line 4
:cond_d
instance-of v0, p1, Lrx/internal/util/ScalarSynchronousObservable;
if-eqz v0, :cond_1b
.line 5
check-cast p1, Lrx/internal/util/ScalarSynchronousObservable;
invoke-virtual {p1}, Lrx/internal/util/ScalarSynchronousObservable;->get()Ljava/lang/Object;
move-result-object p1
invoke-virtual {p0, p1}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->tryEmit(Ljava/lang/Object;)V
goto :goto_30
.line 6
:cond_1b
new-instance v0, Lrx/internal/operators/OperatorMerge$InnerSubscriber;
iget-wide v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->uniqueId:J
const-wide/16 v3, 0x1
add-long/2addr v3, v1
iput-wide v3, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->uniqueId:J
invoke-direct {v0, p0, v1, v2}, Lrx/internal/operators/OperatorMerge$InnerSubscriber;-><init>(Lrx/internal/operators/OperatorMerge$MergeSubscriber;J)V
.line 7
invoke-virtual {p0, v0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->addInner(Lrx/internal/operators/OperatorMerge$InnerSubscriber;)V
.line 8
invoke-virtual {p1, v0}, Lrx/Observable;->unsafeSubscribe(Lrx/Subscriber;)Lrx/Subscription;
.line 9
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emit()V
:goto_30
return-void
.end method
.method protected queueScalar(Ljava/lang/Object;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 11
iget-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->queue:Ljava/util/Queue;
if-nez v0, :cond_33
.line 12
iget v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->maxConcurrent:I
const v1, 0x7fffffff
if-ne v0, v1, :cond_13
.line 13
new-instance v0, Lrx/internal/util/atomic/SpscUnboundedAtomicArrayQueue;
sget v1, Lrx/internal/util/RxRingBuffer;->SIZE:I
invoke-direct {v0, v1}, Lrx/internal/util/atomic/SpscUnboundedAtomicArrayQueue;-><init>(I)V
goto :goto_31
.line 14
:cond_13
invoke-static {v0}, Lrx/internal/util/unsafe/Pow2;->isPowerOfTwo(I)Z
move-result v1
if-eqz v1, :cond_2b
.line 15
invoke-static {}, Lrx/internal/util/unsafe/UnsafeAccess;->isUnsafeAvailable()Z
move-result v1
if-eqz v1, :cond_25
.line 16
new-instance v1, Lrx/internal/util/unsafe/SpscArrayQueue;
invoke-direct {v1, v0}, Lrx/internal/util/unsafe/SpscArrayQueue;-><init>(I)V
goto :goto_30
.line 17
:cond_25
new-instance v1, Lrx/internal/util/atomic/SpscAtomicArrayQueue;
invoke-direct {v1, v0}, Lrx/internal/util/atomic/SpscAtomicArrayQueue;-><init>(I)V
goto :goto_30
.line 18
:cond_2b
new-instance v1, Lrx/internal/util/atomic/SpscExactAtomicArrayQueue;
invoke-direct {v1, v0}, Lrx/internal/util/atomic/SpscExactAtomicArrayQueue;-><init>(I)V
:goto_30
move-object v0, v1
.line 19
:goto_31
iput-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->queue:Ljava/util/Queue;
.line 20
:cond_33
invoke-static {p1}, Lrx/internal/operators/NotificationLite;->next(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
invoke-interface {v0, v1}, Ljava/util/Queue;->offer(Ljava/lang/Object;)Z
move-result v0
if-nez v0, :cond_4c
.line 21
invoke-virtual {p0}, Lrx/Subscriber;->unsubscribe()V
.line 22
new-instance v0, Lrx/exceptions/MissingBackpressureException;
invoke-direct {v0}, Lrx/exceptions/MissingBackpressureException;-><init>()V
invoke-static {v0, p1}, Lrx/exceptions/OnErrorThrowable;->addValueAsLastCause(Ljava/lang/Throwable;Ljava/lang/Object;)Ljava/lang/Throwable;
move-result-object p1
invoke-virtual {p0, p1}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->onError(Ljava/lang/Throwable;)V
:cond_4c
return-void
.end method
.method protected queueScalar(Lrx/internal/operators/OperatorMerge$InnerSubscriber;Ljava/lang/Object;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/internal/operators/OperatorMerge$InnerSubscriber<",
"TT;>;TT;)V"
}
.end annotation
.line 1
iget-object v0, p1, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->queue:Lrx/internal/util/RxRingBuffer;
if-nez v0, :cond_d
.line 2
invoke-static {}, Lrx/internal/util/RxRingBuffer;->getSpscInstance()Lrx/internal/util/RxRingBuffer;
move-result-object v0
.line 3
invoke-virtual {p1, v0}, Lrx/Subscriber;->add(Lrx/Subscription;)V
.line 4
iput-object v0, p1, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->queue:Lrx/internal/util/RxRingBuffer;
.line 5
:cond_d
:try_start_d
invoke-static {p2}, Lrx/internal/operators/NotificationLite;->next(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object p2
invoke-virtual {v0, p2}, Lrx/internal/util/RxRingBuffer;->onNext(Ljava/lang/Object;)V
:try_end_14
.catch Lrx/exceptions/MissingBackpressureException; {:try_start_d .. :try_end_14} :catch_23
.catch Ljava/lang/IllegalStateException; {:try_start_d .. :try_end_14} :catch_15
goto :goto_2a
:catch_15
move-exception p2
.line 6
invoke-virtual {p1}, Lrx/Subscriber;->isUnsubscribed()Z
move-result v0
if-nez v0, :cond_2a
.line 7
invoke-virtual {p1}, Lrx/Subscriber;->unsubscribe()V
.line 8
invoke-virtual {p1, p2}, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->onError(Ljava/lang/Throwable;)V
goto :goto_2a
:catch_23
move-exception p2
.line 9
invoke-virtual {p1}, Lrx/Subscriber;->unsubscribe()V
.line 10
invoke-virtual {p1, p2}, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->onError(Ljava/lang/Throwable;)V
:cond_2a
:goto_2a
return-void
.end method
.method removeInner(Lrx/internal/operators/OperatorMerge$InnerSubscriber;)V
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/internal/operators/OperatorMerge$InnerSubscriber<",
"TT;>;)V"
}
.end annotation
.line 1
iget-object v0, p1, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->queue:Lrx/internal/util/RxRingBuffer;
if-eqz v0, :cond_7
.line 2
invoke-virtual {v0}, Lrx/internal/util/RxRingBuffer;->release()V
.line 3
:cond_7
iget-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->subscriptions:Lrx/subscriptions/CompositeSubscription;
invoke-virtual {v0, p1}, Lrx/subscriptions/CompositeSubscription;->remove(Lrx/Subscription;)V
.line 4
iget-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->innerGuard:Ljava/lang/Object;
monitor-enter v0
.line 5
:try_start_f
iget-object v1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->innerSubscribers:[Lrx/internal/operators/OperatorMerge$InnerSubscriber;
.line 6
array-length v2, v1
const/4 v3, -0x1
const/4 v4, 0x0
const/4 v5, 0x0
:goto_15
if-ge v5, v2, :cond_24
.line 7
aget-object v6, v1, v5
invoke-virtual {p1, v6}, Ljava/lang/Object;->equals(Ljava/lang/Object;)Z
move-result v6
if-eqz v6, :cond_21
move v3, v5
goto :goto_24
:cond_21
add-int/lit8 v5, v5, 0x1
goto :goto_15
:cond_24
:goto_24
if-gez v3, :cond_28
.line 8
monitor-exit v0
return-void
:cond_28
const/4 p1, 0x1
if-ne v2, p1, :cond_31
.line 9
sget-object p1, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->EMPTY:[Lrx/internal/operators/OperatorMerge$InnerSubscriber;
iput-object p1, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->innerSubscribers:[Lrx/internal/operators/OperatorMerge$InnerSubscriber;
.line 10
monitor-exit v0
return-void
:cond_31
add-int/lit8 v5, v2, -0x1
.line 11
new-array v5, v5, [Lrx/internal/operators/OperatorMerge$InnerSubscriber;
.line 12
invoke-static {v1, v4, v5, v4, v3}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
add-int/lit8 v4, v3, 0x1
sub-int/2addr v2, v3
sub-int/2addr v2, p1
.line 13
invoke-static {v1, v4, v5, v3, v2}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
.line 14
iput-object v5, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->innerSubscribers:[Lrx/internal/operators/OperatorMerge$InnerSubscriber;
.line 15
monitor-exit v0
return-void
:catchall_43
move-exception p1
monitor-exit v0
:try_end_45
.catchall {:try_start_f .. :try_end_45} :catchall_43
goto :goto_47
:goto_46
throw p1
:goto_47
goto :goto_46
.end method
.method public requestMore(J)V
.registers 3
.line 1
invoke-virtual {p0, p1, p2}, Lrx/Subscriber;->request(J)V
return-void
.end method
.method tryEmit(Ljava/lang/Object;)V
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 14
iget-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->producer:Lrx/internal/operators/OperatorMerge$MergeProducer;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v0
const-wide/16 v2, 0x0
const/4 v4, 0x0
cmp-long v5, v0, v2
if-eqz v5, :cond_25
.line 15
monitor-enter p0
.line 16
:try_start_e
iget-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->producer:Lrx/internal/operators/OperatorMerge$MergeProducer;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v0
.line 17
iget-boolean v5, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitting:Z
const/4 v6, 0x1
if-nez v5, :cond_20
cmp-long v5, v0, v2
if-eqz v5, :cond_20
.line 18
iput-boolean v6, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitting:Z
const/4 v4, 0x1
.line 19
:cond_20
monitor-exit p0
goto :goto_25
:catchall_22
move-exception p1
monitor-exit p0
:try_end_24
.catchall {:try_start_e .. :try_end_24} :catchall_22
throw p1
:cond_25
:goto_25
if-eqz v4, :cond_3d
.line 20
iget-object v2, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->queue:Ljava/util/Queue;
if-eqz v2, :cond_39
.line 21
invoke-interface {v2}, Ljava/util/Queue;->isEmpty()Z
move-result v2
if-eqz v2, :cond_32
goto :goto_39
.line 22
:cond_32
invoke-virtual {p0, p1}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->queueScalar(Ljava/lang/Object;)V
.line 23
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitLoop()V
goto :goto_43
.line 24
:cond_39
:goto_39
invoke-virtual {p0, p1, v0, v1}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitScalar(Ljava/lang/Object;J)V
goto :goto_43
.line 25
:cond_3d
invoke-virtual {p0, p1}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->queueScalar(Ljava/lang/Object;)V
.line 26
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emit()V
:goto_43
return-void
.end method
.method tryEmit(Lrx/internal/operators/OperatorMerge$InnerSubscriber;Ljava/lang/Object;)V
.registers 10
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lrx/internal/operators/OperatorMerge$InnerSubscriber<",
"TT;>;TT;)V"
}
.end annotation
.line 1
iget-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->producer:Lrx/internal/operators/OperatorMerge$MergeProducer;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v0
const-wide/16 v2, 0x0
const/4 v4, 0x0
cmp-long v5, v0, v2
if-eqz v5, :cond_25
.line 2
monitor-enter p0
.line 3
:try_start_e
iget-object v0, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->producer:Lrx/internal/operators/OperatorMerge$MergeProducer;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicLong;->get()J
move-result-wide v0
.line 4
iget-boolean v5, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitting:Z
const/4 v6, 0x1
if-nez v5, :cond_20
cmp-long v5, v0, v2
if-eqz v5, :cond_20
.line 5
iput-boolean v6, p0, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitting:Z
const/4 v4, 0x1
.line 6
:cond_20
monitor-exit p0
goto :goto_25
:catchall_22
move-exception p1
monitor-exit p0
:try_end_24
.catchall {:try_start_e .. :try_end_24} :catchall_22
throw p1
:cond_25
:goto_25
if-eqz v4, :cond_3d
.line 7
iget-object v2, p1, Lrx/internal/operators/OperatorMerge$InnerSubscriber;->queue:Lrx/internal/util/RxRingBuffer;
if-eqz v2, :cond_39
.line 8
invoke-virtual {v2}, Lrx/internal/util/RxRingBuffer;->isEmpty()Z
move-result v2
if-eqz v2, :cond_32
goto :goto_39
.line 9
:cond_32
invoke-virtual {p0, p1, p2}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->queueScalar(Lrx/internal/operators/OperatorMerge$InnerSubscriber;Ljava/lang/Object;)V
.line 10
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitLoop()V
goto :goto_43
.line 11
:cond_39
:goto_39
invoke-virtual {p0, p1, p2, v0, v1}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emitScalar(Lrx/internal/operators/OperatorMerge$InnerSubscriber;Ljava/lang/Object;J)V
goto :goto_43
.line 12
:cond_3d
invoke-virtual {p0, p1, p2}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->queueScalar(Lrx/internal/operators/OperatorMerge$InnerSubscriber;Ljava/lang/Object;)V
.line 13
invoke-virtual {p0}, Lrx/internal/operators/OperatorMerge$MergeSubscriber;->emit()V
:goto_43
return-void
.end method