final class io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer<T> extends java.util.concurrent.atomic.AtomicReference<java.lang.Object> implements io.reactivex.subjects.ReplaySubject$ReplayBuffer<T>
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer
super_class: java.util.concurrent.atomic.AtomicReference
{
private static final long serialVersionUID;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: -733876083048047795
final java.util.List<java.lang.Object> buffer;
descriptor: Ljava/util/List;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/List<Ljava/lang/Object;>;
volatile boolean done;
descriptor: Z
flags: (0x0040) ACC_VOLATILE
volatile int size;
descriptor: I
flags: (0x0040) ACC_VOLATILE
void <init>(int);
descriptor: (I)V
flags: (0x0000)
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
1: aload 0
new java.util.ArrayList
dup
iload 1
ldc "capacityHint"
invokestatic io.reactivex.internal.functions.ObjectHelper.verifyPositive:(ILjava/lang/String;)I
invokespecial java.util.ArrayList.<init>:(I)V
putfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.buffer:Ljava/util/List;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/subjects/ReplaySubject$UnboundedReplayBuffer<TT;>;
0 3 1 capacityHint I
MethodParameters:
Name Flags
capacityHint
public void add();
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.buffer:Ljava/util/List;
aload 1
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
1: aload 0
dup
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.size:I
iconst_1
iadd
putfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.size:I
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/subjects/ReplaySubject$UnboundedReplayBuffer<TT;>;
0 3 1 value TT;
Signature: (TT;)V
MethodParameters:
Name Flags
value
public void addFinal(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.buffer:Ljava/util/List;
aload 1
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
1: aload 0
invokevirtual io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.trimHead:()V
2: aload 0
dup
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.size:I
iconst_1
iadd
putfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.size:I
3: aload 0
iconst_1
putfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.done:Z
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactivex/subjects/ReplaySubject$UnboundedReplayBuffer<TT;>;
0 5 1 notificationLite Ljava/lang/Object;
MethodParameters:
Name Flags
notificationLite
public void trimHead();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=0, locals=1, args_size=1
start local 0 0: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/subjects/ReplaySubject$UnboundedReplayBuffer<TT;>;
public T getValue();
descriptor: ()Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=1
start local 0 0: aload 0
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.size:I
istore 1
start local 1 1: iload 1
ifeq 9
2: aload 0
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.buffer:Ljava/util/List;
astore 2
start local 2 3: aload 2
iload 1
iconst_1
isub
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
astore 3
start local 3 4: aload 3
invokestatic io.reactivex.internal.util.NotificationLite.isComplete:(Ljava/lang/Object;)Z
ifne 5
aload 3
invokestatic io.reactivex.internal.util.NotificationLite.isError:(Ljava/lang/Object;)Z
ifeq 8
5: StackMap locals: int java.util.List java.lang.Object
StackMap stack:
iload 1
iconst_1
if_icmpne 7
6: aconst_null
areturn
7: StackMap locals:
StackMap stack:
aload 2
iload 1
iconst_2
isub
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
areturn
8: StackMap locals:
StackMap stack:
aload 3
areturn
end local 3 end local 2 9: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/reactivex/subjects/ReplaySubject$UnboundedReplayBuffer<TT;>;
1 10 1 s I
3 9 2 b Ljava/util/List<Ljava/lang/Object;>;
4 9 3 o Ljava/lang/Object;
Signature: ()TT;
RuntimeInvisibleAnnotations:
io.reactivex.annotations.Nullable()
public T[] getValues();
descriptor: ([Ljava/lang/Object;)[Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=6, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.size:I
istore 2
start local 2 1: iload 2
ifne 5
2: aload 1
arraylength
ifeq 4
3: aload 1
iconst_0
aconst_null
aastore
4: StackMap locals: int
StackMap stack:
aload 1
areturn
5: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.buffer:Ljava/util/List;
astore 3
start local 3 6: aload 3
iload 2
iconst_1
isub
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
astore 4
start local 4 7: aload 4
invokestatic io.reactivex.internal.util.NotificationLite.isComplete:(Ljava/lang/Object;)Z
ifne 8
aload 4
invokestatic io.reactivex.internal.util.NotificationLite.isError:(Ljava/lang/Object;)Z
ifeq 13
8: StackMap locals: java.util.List java.lang.Object
StackMap stack:
iinc 2 -1
9: iload 2
ifne 13
10: aload 1
arraylength
ifeq 12
11: aload 1
iconst_0
aconst_null
aastore
12: StackMap locals:
StackMap stack:
aload 1
areturn
13: StackMap locals:
StackMap stack:
aload 1
arraylength
iload 2
if_icmpge 15
14: aload 1
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getComponentType:()Ljava/lang/Class;
iload 2
invokestatic java.lang.reflect.Array.newInstance:(Ljava/lang/Class;I)Ljava/lang/Object;
checkcast java.lang.Object[]
astore 1
15: StackMap locals:
StackMap stack:
iconst_0
istore 5
start local 5 16: goto 19
17: StackMap locals: int
StackMap stack:
aload 1
iload 5
aload 3
iload 5
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
aastore
18: iinc 5 1
StackMap locals:
StackMap stack:
19: iload 5
iload 2
if_icmplt 17
end local 5 20: aload 1
arraylength
iload 2
if_icmple 22
21: aload 1
iload 2
aconst_null
aastore
22: StackMap locals:
StackMap stack:
aload 1
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 23 0 this Lio/reactivex/subjects/ReplaySubject$UnboundedReplayBuffer<TT;>;
0 23 1 array [Ljava/lang/Object;
1 23 2 s I
6 23 3 b Ljava/util/List<Ljava/lang/Object;>;
7 23 4 o Ljava/lang/Object;
16 20 5 i I
Signature: ([TT;)[TT;
MethodParameters:
Name Flags
array
public void replay(io.reactivex.subjects.ReplaySubject$ReplayDisposable<T>);
descriptor: (Lio/reactivex/subjects/ReplaySubject$ReplayDisposable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=9, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual io.reactivex.subjects.ReplaySubject$ReplayDisposable.getAndIncrement:()I
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
iconst_1
istore 2
start local 2 3: aload 0
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.buffer:Ljava/util/List;
astore 3
start local 3 4: aload 1
getfield io.reactivex.subjects.ReplaySubject$ReplayDisposable.downstream:Lio/reactivex/Observer;
astore 4
start local 4 5: aload 1
getfield io.reactivex.subjects.ReplaySubject$ReplayDisposable.index:Ljava/lang/Object;
checkcast java.lang.Integer
astore 5
start local 5 6: aload 5
ifnull 9
7: aload 5
invokevirtual java.lang.Integer.intValue:()I
istore 6
start local 6 8: goto 11
end local 6 9: StackMap locals: io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer io.reactivex.subjects.ReplaySubject$ReplayDisposable int java.util.List io.reactivex.Observer java.lang.Integer
StackMap stack:
iconst_0
istore 6
start local 6 10: aload 1
iconst_0
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
putfield io.reactivex.subjects.ReplaySubject$ReplayDisposable.index:Ljava/lang/Object;
11: StackMap locals: int
StackMap stack:
aload 1
getfield io.reactivex.subjects.ReplaySubject$ReplayDisposable.cancelled:Z
ifeq 14
12: aload 1
aconst_null
putfield io.reactivex.subjects.ReplaySubject$ReplayDisposable.index:Ljava/lang/Object;
13: return
14: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.size:I
istore 7
start local 7 15: goto 33
16: StackMap locals: int
StackMap stack:
aload 1
getfield io.reactivex.subjects.ReplaySubject$ReplayDisposable.cancelled:Z
ifeq 19
17: aload 1
aconst_null
putfield io.reactivex.subjects.ReplaySubject$ReplayDisposable.index:Ljava/lang/Object;
18: return
19: StackMap locals:
StackMap stack:
aload 3
iload 6
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
astore 8
start local 8 20: aload 0
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.done:Z
ifeq 31
21: iload 6
iconst_1
iadd
iload 7
if_icmpne 31
22: aload 0
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.size:I
istore 7
23: iload 6
iconst_1
iadd
iload 7
if_icmpne 31
24: aload 8
invokestatic io.reactivex.internal.util.NotificationLite.isComplete:(Ljava/lang/Object;)Z
ifeq 27
25: aload 4
invokeinterface io.reactivex.Observer.onComplete:()V
26: goto 28
27: StackMap locals: java.lang.Object
StackMap stack:
aload 4
aload 8
invokestatic io.reactivex.internal.util.NotificationLite.getError:(Ljava/lang/Object;)Ljava/lang/Throwable;
invokeinterface io.reactivex.Observer.onError:(Ljava/lang/Throwable;)V
28: StackMap locals:
StackMap stack:
aload 1
aconst_null
putfield io.reactivex.subjects.ReplaySubject$ReplayDisposable.index:Ljava/lang/Object;
29: aload 1
iconst_1
putfield io.reactivex.subjects.ReplaySubject$ReplayDisposable.cancelled:Z
30: return
31: StackMap locals:
StackMap stack:
aload 4
aload 8
invokeinterface io.reactivex.Observer.onNext:(Ljava/lang/Object;)V
32: iinc 6 1
end local 8 33: StackMap locals:
StackMap stack:
iload 7
iload 6
if_icmpne 16
34: iload 6
aload 0
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.size:I
if_icmpeq 36
35: goto 11
36: StackMap locals:
StackMap stack:
aload 1
iload 6
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
putfield io.reactivex.subjects.ReplaySubject$ReplayDisposable.index:Ljava/lang/Object;
37: aload 1
iload 2
ineg
invokevirtual io.reactivex.subjects.ReplaySubject$ReplayDisposable.addAndGet:(I)I
istore 2
38: iload 2
ifne 11
end local 7 39: return
end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 40 0 this Lio/reactivex/subjects/ReplaySubject$UnboundedReplayBuffer<TT;>;
0 40 1 rs Lio/reactivex/subjects/ReplaySubject$ReplayDisposable<TT;>;
3 40 2 missed I
4 40 3 b Ljava/util/List<Ljava/lang/Object;>;
5 40 4 a Lio/reactivex/Observer<-TT;>;
6 40 5 indexObject Ljava/lang/Integer;
8 9 6 index I
10 40 6 index I
15 39 7 s I
20 33 8 o Ljava/lang/Object;
Signature: (Lio/reactivex/subjects/ReplaySubject$ReplayDisposable<TT;>;)V
MethodParameters:
Name Flags
rs
public int size();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=1
start local 0 0: aload 0
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.size:I
istore 1
start local 1 1: iload 1
ifeq 6
2: aload 0
getfield io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer.buffer:Ljava/util/List;
iload 1
iconst_1
isub
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
astore 2
start local 2 3: aload 2
invokestatic io.reactivex.internal.util.NotificationLite.isComplete:(Ljava/lang/Object;)Z
ifne 4
aload 2
invokestatic io.reactivex.internal.util.NotificationLite.isError:(Ljava/lang/Object;)Z
ifeq 5
4: StackMap locals: int java.lang.Object
StackMap stack:
iload 1
iconst_1
isub
ireturn
5: StackMap locals:
StackMap stack:
iload 1
ireturn
end local 2 6: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/reactivex/subjects/ReplaySubject$UnboundedReplayBuffer<TT;>;
1 7 1 s I
3 6 2 o Ljava/lang/Object;
}
Signature: <T:Ljava/lang/Object;>Ljava/util/concurrent/atomic/AtomicReference<Ljava/lang/Object;>;Lio/reactivex/subjects/ReplaySubject$ReplayBuffer<TT;>;
SourceFile: "ReplaySubject.java"
NestHost: io.reactivex.subjects.ReplaySubject
InnerClasses:
abstract ReplayBuffer = io.reactivex.subjects.ReplaySubject$ReplayBuffer of io.reactivex.subjects.ReplaySubject
final ReplayDisposable = io.reactivex.subjects.ReplaySubject$ReplayDisposable of io.reactivex.subjects.ReplaySubject
final UnboundedReplayBuffer = io.reactivex.subjects.ReplaySubject$UnboundedReplayBuffer of io.reactivex.subjects.ReplaySubject