BehaviorProcessor.smali
.class public final Lio/reactivex/processors/BehaviorProcessor;
.super Lio/reactivex/processors/FlowableProcessor;
.source "BehaviorProcessor.java"
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
}
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">",
"Lio/reactivex/processors/FlowableProcessor<",
"TT;>;"
}
.end annotation
# static fields
.field static final EMPTY:[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
.field static final EMPTY_ARRAY:[Ljava/lang/Object;
.field static final TERMINATED:[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
# instance fields
.field index:J
.field final lock:Ljava/util/concurrent/locks/ReadWriteLock;
.field final readLock:Ljava/util/concurrent/locks/Lock;
.field final subscribers:Ljava/util/concurrent/atomic/AtomicReference;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReference<",
"[",
"Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<",
"TT;>;>;"
}
.end annotation
.end field
.field final terminalEvent:Ljava/util/concurrent/atomic/AtomicReference;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/atomic/AtomicReference<",
"Ljava/lang/Throwable;",
">;"
}
.end annotation
.end field
.field final value: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 writeLock:Ljava/util/concurrent/locks/Lock;
# direct methods
.method static constructor <clinit>()V
.registers 2
.line 75
const/4 v0, 0x0
new-array v1, v0, [Ljava/lang/Object;
sput-object v1, Lio/reactivex/processors/BehaviorProcessor;->EMPTY_ARRAY:[Ljava/lang/Object;
.line 78
new-array v1, v0, [Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
sput-object v1, Lio/reactivex/processors/BehaviorProcessor;->EMPTY:[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
.line 81
new-array v0, v0, [Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
sput-object v0, Lio/reactivex/processors/BehaviorProcessor;->TERMINATED:[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
return-void
.end method
.method constructor <init>()V
.registers 3
.line 127
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
invoke-direct {p0}, Lio/reactivex/processors/FlowableProcessor;-><init>()V
.line 128
new-instance v0, Ljava/util/concurrent/atomic/AtomicReference;
invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
iput-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->value:Ljava/util/concurrent/atomic/AtomicReference;
.line 129
new-instance v0, Ljava/util/concurrent/locks/ReentrantReadWriteLock;
invoke-direct {v0}, Ljava/util/concurrent/locks/ReentrantReadWriteLock;-><init>()V
iput-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->lock:Ljava/util/concurrent/locks/ReadWriteLock;
.line 130
invoke-interface {v0}, Ljava/util/concurrent/locks/ReadWriteLock;->readLock()Ljava/util/concurrent/locks/Lock;
move-result-object v0
iput-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->readLock:Ljava/util/concurrent/locks/Lock;
.line 131
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->lock:Ljava/util/concurrent/locks/ReadWriteLock;
invoke-interface {v0}, Ljava/util/concurrent/locks/ReadWriteLock;->writeLock()Ljava/util/concurrent/locks/Lock;
move-result-object v0
iput-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->writeLock:Ljava/util/concurrent/locks/Lock;
.line 132
new-instance v0, Ljava/util/concurrent/atomic/AtomicReference;
sget-object v1, Lio/reactivex/processors/BehaviorProcessor;->EMPTY:[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
invoke-direct {v0, v1}, Ljava/util/concurrent/atomic/AtomicReference;-><init>(Ljava/lang/Object;)V
iput-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
.line 133
new-instance v0, Ljava/util/concurrent/atomic/AtomicReference;
invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicReference;-><init>()V
iput-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->terminalEvent:Ljava/util/concurrent/atomic/AtomicReference;
.line 134
return-void
.end method
.method constructor <init>(Ljava/lang/Object;)V
.registers 4
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 143
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
.local p1, "defaultValue":Ljava/lang/Object;, "TT;"
invoke-direct {p0}, Lio/reactivex/processors/BehaviorProcessor;-><init>()V
.line 144
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->value:Ljava/util/concurrent/atomic/AtomicReference;
const-string v1, "defaultValue is null"
invoke-static {p1, v1}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
move-result-object v1
invoke-virtual {v0, v1}, Ljava/util/concurrent/atomic/AtomicReference;->lazySet(Ljava/lang/Object;)V
.line 145
return-void
.end method
.method public static create()Lio/reactivex/processors/BehaviorProcessor;
.registers 1
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">()",
"Lio/reactivex/processors/BehaviorProcessor<",
"TT;>;"
}
.end annotation
.annotation runtime Lio/reactivex/annotations/CheckReturnValue;
.end annotation
.line 102
new-instance v0, Lio/reactivex/processors/BehaviorProcessor;
invoke-direct {v0}, Lio/reactivex/processors/BehaviorProcessor;-><init>()V
return-object v0
.end method
.method public static createDefault(Ljava/lang/Object;)Lio/reactivex/processors/BehaviorProcessor;
.registers 2
.annotation system Ldalvik/annotation/Signature;
value = {
"<T:",
"Ljava/lang/Object;",
">(TT;)",
"Lio/reactivex/processors/BehaviorProcessor<",
"TT;>;"
}
.end annotation
.annotation runtime Lio/reactivex/annotations/CheckReturnValue;
.end annotation
.line 118
.local p0, "defaultValue":Ljava/lang/Object;, "TT;"
const-string v0, "defaultValue is null"
invoke-static {p0, v0}, Lio/reactivex/internal/functions/ObjectHelper;->requireNonNull(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
.line 119
new-instance v0, Lio/reactivex/processors/BehaviorProcessor;
invoke-direct {v0, p0}, Lio/reactivex/processors/BehaviorProcessor;-><init>(Ljava/lang/Object;)V
return-object v0
.end method
# virtual methods
.method add(Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;)Z
.registers 6
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<",
"TT;>;)Z"
}
.end annotation
.line 356
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
.local p1, "rs":Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
:goto_0
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
check-cast v0, [Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
.line 357
.local v0, "a":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
sget-object v1, Lio/reactivex/processors/BehaviorProcessor;->TERMINATED:[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
const/4 v2, 0x0
if-ne v0, v1, :cond_e
.line 358
return v2
.line 360
:cond_e
array-length v1, v0
.line 362
.local v1, "len":I
add-int/lit8 v3, v1, 0x1
new-array v3, v3, [Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
.line 363
.local v3, "b":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
invoke-static {v0, v2, v3, v2, v1}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
.line 364
aput-object p1, v3, v1
.line 365
iget-object v2, p0, Lio/reactivex/processors/BehaviorProcessor;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v2, v0, v3}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z
move-result v2
if-eqz v2, :cond_22
.line 366
const/4 v2, 0x1
return v2
.line 368
.end local v0 # "a":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
.end local v1 # "len":I
.end local v3 # "b":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
:cond_22
goto :goto_0
.end method
.method public getThrowable()Ljava/lang/Throwable;
.registers 3
.line 265
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->value:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
.line 266
.local v0, "o":Ljava/lang/Object;
invoke-static {v0}, Lio/reactivex/internal/util/NotificationLite;->isError(Ljava/lang/Object;)Z
move-result v1
if-eqz v1, :cond_11
.line 267
invoke-static {v0}, Lio/reactivex/internal/util/NotificationLite;->getError(Ljava/lang/Object;)Ljava/lang/Throwable;
move-result-object v1
return-object v1
.line 269
:cond_11
const/4 v1, 0x0
return-object v1
.end method
.method public getValue()Ljava/lang/Object;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"()TT;"
}
.end annotation
.line 278
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->value:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
.line 279
.local v0, "o":Ljava/lang/Object;
invoke-static {v0}, Lio/reactivex/internal/util/NotificationLite;->isComplete(Ljava/lang/Object;)Z
move-result v1
if-nez v1, :cond_18
invoke-static {v0}, Lio/reactivex/internal/util/NotificationLite;->isError(Ljava/lang/Object;)Z
move-result v1
if-eqz v1, :cond_13
goto :goto_18
.line 282
:cond_13
invoke-static {v0}, Lio/reactivex/internal/util/NotificationLite;->getValue(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
return-object v1
.line 280
:cond_18
:goto_18
const/4 v1, 0x0
return-object v1
.end method
.method public getValues()[Ljava/lang/Object;
.registers 4
.line 292
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
sget-object v0, Lio/reactivex/processors/BehaviorProcessor;->EMPTY_ARRAY:[Ljava/lang/Object;
check-cast v0, [Ljava/lang/Object;
.line 293
.local v0, "a":[Ljava/lang/Object;, "[TT;"
invoke-virtual {p0, v0}, Lio/reactivex/processors/BehaviorProcessor;->getValues([Ljava/lang/Object;)[Ljava/lang/Object;
move-result-object v1
.line 294
.local v1, "b":[Ljava/lang/Object;, "[TT;"
sget-object v2, Lio/reactivex/processors/BehaviorProcessor;->EMPTY_ARRAY:[Ljava/lang/Object;
if-ne v1, v2, :cond_10
.line 295
const/4 v2, 0x0
new-array v2, v2, [Ljava/lang/Object;
return-object v2
.line 297
:cond_10
return-object v1
.end method
.method public getValues([Ljava/lang/Object;)[Ljava/lang/Object;
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"([TT;)[TT;"
}
.end annotation
.line 311
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
.local p1, "array":[Ljava/lang/Object;, "[TT;"
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->value:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
.line 312
.local v0, "o":Ljava/lang/Object;
const/4 v1, 0x0
const/4 v2, 0x0
if-eqz v0, :cond_3b
invoke-static {v0}, Lio/reactivex/internal/util/NotificationLite;->isComplete(Ljava/lang/Object;)Z
move-result v3
if-nez v3, :cond_3b
invoke-static {v0}, Lio/reactivex/internal/util/NotificationLite;->isError(Ljava/lang/Object;)Z
move-result v3
if-eqz v3, :cond_17
goto :goto_3b
.line 318
:cond_17
invoke-static {v0}, Lio/reactivex/internal/util/NotificationLite;->getValue(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v3
.line 319
.local v3, "v":Ljava/lang/Object;, "TT;"
array-length v4, p1
const/4 v5, 0x1
if-eqz v4, :cond_27
.line 320
aput-object v3, p1, v2
.line 321
array-length v2, p1
if-eq v2, v5, :cond_3a
.line 322
aput-object v1, p1, v5
goto :goto_3a
.line 325
:cond_27
invoke-virtual {p1}, Ljava/lang/Object;->getClass()Ljava/lang/Class;
move-result-object v1
invoke-virtual {v1}, Ljava/lang/Class;->getComponentType()Ljava/lang/Class;
move-result-object v1
invoke-static {v1, v5}, Ljava/lang/reflect/Array;->newInstance(Ljava/lang/Class;I)Ljava/lang/Object;
move-result-object v1
check-cast v1, [Ljava/lang/Object;
move-object p1, v1
check-cast p1, [Ljava/lang/Object;
.line 326
aput-object v3, p1, v2
.line 328
:cond_3a
:goto_3a
return-object p1
.line 313
.end local v3 # "v":Ljava/lang/Object;, "TT;"
:cond_3b
:goto_3b
array-length v3, p1
if-eqz v3, :cond_40
.line 314
aput-object v1, p1, v2
.line 316
:cond_40
return-object p1
.end method
.method public hasComplete()Z
.registers 3
.line 333
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->value:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
.line 334
.local v0, "o":Ljava/lang/Object;
invoke-static {v0}, Lio/reactivex/internal/util/NotificationLite;->isComplete(Ljava/lang/Object;)Z
move-result v1
return v1
.end method
.method public hasSubscribers()Z
.registers 2
.line 255
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
check-cast v0, [Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
array-length v0, v0
if-eqz v0, :cond_d
const/4 v0, 0x1
goto :goto_e
:cond_d
const/4 v0, 0x0
:goto_e
return v0
.end method
.method public hasThrowable()Z
.registers 3
.line 339
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->value:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
.line 340
.local v0, "o":Ljava/lang/Object;
invoke-static {v0}, Lio/reactivex/internal/util/NotificationLite;->isError(Ljava/lang/Object;)Z
move-result v1
return v1
.end method
.method public hasValue()Z
.registers 3
.line 349
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->value:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
.line 350
.local v0, "o":Ljava/lang/Object;
if-eqz v0, :cond_16
invoke-static {v0}, Lio/reactivex/internal/util/NotificationLite;->isComplete(Ljava/lang/Object;)Z
move-result v1
if-nez v1, :cond_16
invoke-static {v0}, Lio/reactivex/internal/util/NotificationLite;->isError(Ljava/lang/Object;)Z
move-result v1
if-nez v1, :cond_16
const/4 v1, 0x1
goto :goto_17
:cond_16
const/4 v1, 0x0
:goto_17
return v1
.end method
.method public offer(Ljava/lang/Object;)Z
.registers 10
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)Z"
}
.end annotation
.line 233
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
.local p1, "t":Ljava/lang/Object;, "TT;"
const/4 v0, 0x1
if-nez p1, :cond_e
.line 234
new-instance v1, Ljava/lang/NullPointerException;
const-string v2, "onNext called with null. Null values are generally not allowed in 2.x operators and sources."
invoke-direct {v1, v2}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
invoke-virtual {p0, v1}, Lio/reactivex/processors/BehaviorProcessor;->onError(Ljava/lang/Throwable;)V
.line 235
return v0
.line 237
:cond_e
iget-object v1, p0, Lio/reactivex/processors/BehaviorProcessor;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v1}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v1
check-cast v1, [Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
.line 239
.local v1, "array":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
array-length v2, v1
const/4 v3, 0x0
const/4 v4, 0x0
:goto_19
if-ge v4, v2, :cond_27
aget-object v5, v1, v4
.line 240
.local v5, "s":Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
invoke-virtual {v5}, Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;->isFull()Z
move-result v6
if-eqz v6, :cond_24
.line 241
return v3
.line 239
.end local v5 # "s":Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
:cond_24
add-int/lit8 v4, v4, 0x1
goto :goto_19
.line 245
:cond_27
invoke-static {p1}, Lio/reactivex/internal/util/NotificationLite;->next(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v2
.line 246
.local v2, "o":Ljava/lang/Object;
invoke-virtual {p0, v2}, Lio/reactivex/processors/BehaviorProcessor;->setCurrent(Ljava/lang/Object;)V
.line 247
array-length v4, v1
:goto_2f
if-ge v3, v4, :cond_3b
aget-object v5, v1, v3
.line 248
.local v5, "bs":Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
iget-wide v6, p0, Lio/reactivex/processors/BehaviorProcessor;->index:J
invoke-virtual {v5, v2, v6, v7}, Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;->emitNext(Ljava/lang/Object;J)V
.line 247
.end local v5 # "bs":Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
add-int/lit8 v3, v3, 0x1
goto :goto_2f
.line 250
:cond_3b
return v0
.end method
.method public onComplete()V
.registers 8
.line 209
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->terminalEvent:Ljava/util/concurrent/atomic/AtomicReference;
sget-object v1, Lio/reactivex/internal/util/ExceptionHelper;->TERMINATED:Ljava/lang/Throwable;
const/4 v2, 0x0
invoke-virtual {v0, v2, v1}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z
move-result v0
if-nez v0, :cond_c
.line 210
return-void
.line 212
:cond_c
invoke-static {}, Lio/reactivex/internal/util/NotificationLite;->complete()Ljava/lang/Object;
move-result-object v0
.line 213
.local v0, "o":Ljava/lang/Object;
invoke-virtual {p0, v0}, Lio/reactivex/processors/BehaviorProcessor;->terminate(Ljava/lang/Object;)[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
move-result-object v1
array-length v2, v1
const/4 v3, 0x0
:goto_16
if-ge v3, v2, :cond_22
aget-object v4, v1, v3
.line 214
.local v4, "bs":Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
iget-wide v5, p0, Lio/reactivex/processors/BehaviorProcessor;->index:J
invoke-virtual {v4, v0, v5, v6}, Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;->emitNext(Ljava/lang/Object;J)V
.line 213
.end local v4 # "bs":Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
add-int/lit8 v3, v3, 0x1
goto :goto_16
.line 216
:cond_22
return-void
.end method
.method public onError(Ljava/lang/Throwable;)V
.registers 9
.param p1, "t" # Ljava/lang/Throwable;
.line 194
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
if-nez p1, :cond_a
.line 195
new-instance v0, Ljava/lang/NullPointerException;
const-string v1, "onError called with null. Null values are generally not allowed in 2.x operators and sources."
invoke-direct {v0, v1}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
move-object p1, v0
.line 197
:cond_a
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->terminalEvent:Ljava/util/concurrent/atomic/AtomicReference;
const/4 v1, 0x0
invoke-virtual {v0, v1, p1}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z
move-result v0
if-nez v0, :cond_17
.line 198
invoke-static {p1}, Lio/reactivex/plugins/RxJavaPlugins;->onError(Ljava/lang/Throwable;)V
.line 199
return-void
.line 201
:cond_17
invoke-static {p1}, Lio/reactivex/internal/util/NotificationLite;->error(Ljava/lang/Throwable;)Ljava/lang/Object;
move-result-object v0
.line 202
.local v0, "o":Ljava/lang/Object;
invoke-virtual {p0, v0}, Lio/reactivex/processors/BehaviorProcessor;->terminate(Ljava/lang/Object;)[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
move-result-object v1
array-length v2, v1
const/4 v3, 0x0
:goto_21
if-ge v3, v2, :cond_2d
aget-object v4, v1, v3
.line 203
.local v4, "bs":Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
iget-wide v5, p0, Lio/reactivex/processors/BehaviorProcessor;->index:J
invoke-virtual {v4, v0, v5, v6}, Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;->emitNext(Ljava/lang/Object;J)V
.line 202
.end local v4 # "bs":Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
add-int/lit8 v3, v3, 0x1
goto :goto_21
.line 205
:cond_2d
return-void
.end method
.method public onNext(Ljava/lang/Object;)V
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
.line 178
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
.local p1, "t":Ljava/lang/Object;, "TT;"
if-nez p1, :cond_d
.line 179
new-instance v0, Ljava/lang/NullPointerException;
const-string v1, "onNext called with null. Null values are generally not allowed in 2.x operators and sources."
invoke-direct {v0, v1}, Ljava/lang/NullPointerException;-><init>(Ljava/lang/String;)V
invoke-virtual {p0, v0}, Lio/reactivex/processors/BehaviorProcessor;->onError(Ljava/lang/Throwable;)V
.line 180
return-void
.line 182
:cond_d
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->terminalEvent:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
if-eqz v0, :cond_16
.line 183
return-void
.line 185
:cond_16
invoke-static {p1}, Lio/reactivex/internal/util/NotificationLite;->next(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v0
.line 186
.local v0, "o":Ljava/lang/Object;
invoke-virtual {p0, v0}, Lio/reactivex/processors/BehaviorProcessor;->setCurrent(Ljava/lang/Object;)V
.line 187
iget-object v1, p0, Lio/reactivex/processors/BehaviorProcessor;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v1}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v1
check-cast v1, [Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
array-length v2, v1
const/4 v3, 0x0
:goto_27
if-ge v3, v2, :cond_33
aget-object v4, v1, v3
.line 188
.local v4, "bs":Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
iget-wide v5, p0, Lio/reactivex/processors/BehaviorProcessor;->index:J
invoke-virtual {v4, v0, v5, v6}, Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;->emitNext(Ljava/lang/Object;J)V
.line 187
.end local v4 # "bs":Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
add-int/lit8 v3, v3, 0x1
goto :goto_27
.line 190
:cond_33
return-void
.end method
.method public onSubscribe(Lorg/reactivestreams/Subscription;)V
.registers 4
.param p1, "s" # Lorg/reactivestreams/Subscription;
.line 169
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->terminalEvent:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
if-eqz v0, :cond_c
.line 170
invoke-interface {p1}, Lorg/reactivestreams/Subscription;->cancel()V
.line 171
return-void
.line 173
:cond_c
const-wide v0, 0x7fffffffffffffffL
invoke-interface {p1, v0, v1}, Lorg/reactivestreams/Subscription;->request(J)V
.line 174
return-void
.end method
.method remove(Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;)V
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<",
"TT;>;)V"
}
.end annotation
.line 374
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
.local p1, "rs":Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
:goto_0
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
check-cast v0, [Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
.line 375
.local v0, "a":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
sget-object v1, Lio/reactivex/processors/BehaviorProcessor;->TERMINATED:[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
if-eq v0, v1, :cond_43
sget-object v1, Lio/reactivex/processors/BehaviorProcessor;->EMPTY:[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
if-ne v0, v1, :cond_11
goto :goto_43
.line 378
:cond_11
array-length v1, v0
.line 379
.local v1, "len":I
const/4 v2, -0x1
.line 380
.local v2, "j":I
const/4 v3, 0x0
.local v3, "i":I
:goto_14
if-ge v3, v1, :cond_1f
.line 381
aget-object v4, v0, v3
if-ne v4, p1, :cond_1c
.line 382
move v2, v3
.line 383
goto :goto_1f
.line 380
:cond_1c
add-int/lit8 v3, v3, 0x1
goto :goto_14
.line 387
.end local v3 # "i":I
:cond_1f
:goto_1f
if-gez v2, :cond_22
.line 388
return-void
.line 391
:cond_22
const/4 v3, 0x1
if-ne v1, v3, :cond_28
.line 392
sget-object v3, Lio/reactivex/processors/BehaviorProcessor;->EMPTY:[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
.local v3, "b":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
goto :goto_39
.line 394
.end local v3 # "b":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
:cond_28
add-int/lit8 v4, v1, -0x1
new-array v4, v4, [Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
.line 395
.local v4, "b":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
const/4 v5, 0x0
invoke-static {v0, v5, v4, v5, v2}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
.line 396
add-int/lit8 v5, v2, 0x1
sub-int v6, v1, v2
sub-int/2addr v6, v3
invoke-static {v0, v5, v4, v2, v6}, Ljava/lang/System;->arraycopy(Ljava/lang/Object;ILjava/lang/Object;II)V
move-object v3, v4
.line 398
.end local v4 # "b":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
.restart local v3 # "b":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
:goto_39
iget-object v4, p0, Lio/reactivex/processors/BehaviorProcessor;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v4, v0, v3}, Ljava/util/concurrent/atomic/AtomicReference;->compareAndSet(Ljava/lang/Object;Ljava/lang/Object;)Z
move-result v4
if-eqz v4, :cond_42
.line 399
return-void
.line 401
.end local v0 # "a":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
.end local v1 # "len":I
.end local v2 # "j":I
.end local v3 # "b":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
:cond_42
goto :goto_0
.line 376
.restart local v0 # "a":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
:cond_43
:goto_43
return-void
.end method
.method setCurrent(Ljava/lang/Object;)V
.registers 7
.param p1, "o" # Ljava/lang/Object;
.line 420
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->writeLock:Ljava/util/concurrent/locks/Lock;
.line 421
.local v0, "wl":Ljava/util/concurrent/locks/Lock;
invoke-interface {v0}, Ljava/util/concurrent/locks/Lock;->lock()V
.line 422
iget-wide v1, p0, Lio/reactivex/processors/BehaviorProcessor;->index:J
const-wide/16 v3, 0x1
add-long/2addr v1, v3
iput-wide v1, p0, Lio/reactivex/processors/BehaviorProcessor;->index:J
.line 423
iget-object v1, p0, Lio/reactivex/processors/BehaviorProcessor;->value:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v1, p1}, Ljava/util/concurrent/atomic/AtomicReference;->lazySet(Ljava/lang/Object;)V
.line 424
invoke-interface {v0}, Ljava/util/concurrent/locks/Lock;->unlock()V
.line 425
return-void
.end method
.method protected subscribeActual(Lorg/reactivestreams/Subscriber;)V
.registers 5
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lorg/reactivestreams/Subscriber<",
"-TT;>;)V"
}
.end annotation
.line 149
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
.local p1, "s":Lorg/reactivestreams/Subscriber;, "Lorg/reactivestreams/Subscriber<-TT;>;"
new-instance v0, Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
invoke-direct {v0, p1, p0}, Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;-><init>(Lorg/reactivestreams/Subscriber;Lio/reactivex/processors/BehaviorProcessor;)V
.line 150
.local v0, "bs":Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
invoke-interface {p1, v0}, Lorg/reactivestreams/Subscriber;->onSubscribe(Lorg/reactivestreams/Subscription;)V
.line 151
invoke-virtual {p0, v0}, Lio/reactivex/processors/BehaviorProcessor;->add(Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;)Z
move-result v1
if-eqz v1, :cond_1a
.line 152
iget-boolean v1, v0, Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;->cancelled:Z
if-eqz v1, :cond_16
.line 153
invoke-virtual {p0, v0}, Lio/reactivex/processors/BehaviorProcessor;->remove(Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;)V
goto :goto_2d
.line 155
:cond_16
invoke-virtual {v0}, Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;->emitFirst()V
goto :goto_2d
.line 158
:cond_1a
iget-object v1, p0, Lio/reactivex/processors/BehaviorProcessor;->terminalEvent:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v1}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v1
check-cast v1, Ljava/lang/Throwable;
.line 159
.local v1, "ex":Ljava/lang/Throwable;
sget-object v2, Lio/reactivex/internal/util/ExceptionHelper;->TERMINATED:Ljava/lang/Throwable;
if-ne v1, v2, :cond_2a
.line 160
invoke-interface {p1}, Lorg/reactivestreams/Subscriber;->onComplete()V
goto :goto_2d
.line 162
:cond_2a
invoke-interface {p1, v1}, Lorg/reactivestreams/Subscriber;->onError(Ljava/lang/Throwable;)V
.line 165
.end local v1 # "ex":Ljava/lang/Throwable;
:goto_2d
return-void
.end method
.method subscriberCount()I
.registers 2
.line 260
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
check-cast v0, [Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
array-length v0, v0
return v0
.end method
.method terminate(Ljava/lang/Object;)[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
.registers 5
.param p1, "terminalValue" # Ljava/lang/Object;
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/Object;",
")[",
"Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<",
"TT;>;"
}
.end annotation
.line 407
.local p0, "this":Lio/reactivex/processors/BehaviorProcessor;, "Lio/reactivex/processors/BehaviorProcessor<TT;>;"
iget-object v0, p0, Lio/reactivex/processors/BehaviorProcessor;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object;
move-result-object v0
check-cast v0, [Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
.line 408
.local v0, "a":[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;, "[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription<TT;>;"
sget-object v1, Lio/reactivex/processors/BehaviorProcessor;->TERMINATED:[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
if-eq v0, v1, :cond_1c
.line 409
iget-object v2, p0, Lio/reactivex/processors/BehaviorProcessor;->subscribers:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v2, v1}, Ljava/util/concurrent/atomic/AtomicReference;->getAndSet(Ljava/lang/Object;)Ljava/lang/Object;
move-result-object v1
move-object v0, v1
check-cast v0, [Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
.line 410
sget-object v1, Lio/reactivex/processors/BehaviorProcessor;->TERMINATED:[Lio/reactivex/processors/BehaviorProcessor$BehaviorSubscription;
if-eq v0, v1, :cond_1c
.line 412
invoke-virtual {p0, p1}, Lio/reactivex/processors/BehaviorProcessor;->setCurrent(Ljava/lang/Object;)V
.line 416
:cond_1c
return-object v0
.end method