final class io.reactivex.internal.operators.observable.ObservableGroupBy$State<T, K> extends java.util.concurrent.atomic.AtomicInteger implements io.reactivex.disposables.Disposable, io.reactivex.ObservableSource<T>
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: io.reactivex.internal.operators.observable.ObservableGroupBy$State
super_class: java.util.concurrent.atomic.AtomicInteger
{
private static final long serialVersionUID;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: -3852313036005250360
final K key;
descriptor: Ljava/lang/Object;
flags: (0x0010) ACC_FINAL
Signature: TK;
final io.reactivex.internal.queue.SpscLinkedArrayQueue<T> queue;
descriptor: Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
flags: (0x0010) ACC_FINAL
Signature: Lio/reactivex/internal/queue/SpscLinkedArrayQueue<TT;>;
final io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver<?, K, T> parent;
descriptor: Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver;
flags: (0x0010) ACC_FINAL
Signature: Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver<*TK;TT;>;
final boolean delayError;
descriptor: Z
flags: (0x0010) ACC_FINAL
volatile boolean done;
descriptor: Z
flags: (0x0040) ACC_VOLATILE
java.lang.Throwable error;
descriptor: Ljava/lang/Throwable;
flags: (0x0000)
final java.util.concurrent.atomic.AtomicBoolean cancelled;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0010) ACC_FINAL
final java.util.concurrent.atomic.AtomicBoolean once;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0010) ACC_FINAL
final java.util.concurrent.atomic.AtomicReference<io.reactivex.Observer<? super T>> actual;
descriptor: Ljava/util/concurrent/atomic/AtomicReference;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/concurrent/atomic/AtomicReference<Lio/reactivex/Observer<-TT;>;>;
void <init>(int, io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver<?, K, T>, K, );
descriptor: (ILio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver;Ljava/lang/Object;Z)V
flags: (0x0000)
Code:
stack=4, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
1: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:()V
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
2: aload 0
new java.util.concurrent.atomic.AtomicBoolean
dup
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:()V
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.once:Ljava/util/concurrent/atomic/AtomicBoolean;
3: aload 0
new java.util.concurrent.atomic.AtomicReference
dup
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.actual:Ljava/util/concurrent/atomic/AtomicReference;
4: aload 0
new io.reactivex.internal.queue.SpscLinkedArrayQueue
dup
iload 1
invokespecial io.reactivex.internal.queue.SpscLinkedArrayQueue.<init>:(I)V
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
5: aload 0
aload 2
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.parent:Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver;
6: aload 0
aload 3
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.key:Ljava/lang/Object;
7: aload 0
iload 4
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.delayError:Z
8: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$State<TT;TK;>;
0 9 1 bufferSize I
0 9 2 parent Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver<*TK;TT;>;
0 9 3 key TK;
0 9 4 delayError Z
Signature: (ILio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver<*TK;TT;>;TK;Z)V
MethodParameters:
Name Flags
bufferSize
parent
key
delayError
public void dispose();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_0
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
ifeq 4
1: aload 0
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$State.getAndIncrement:()I
ifne 4
2: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.actual:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.lazySet:(Ljava/lang/Object;)V
3: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.parent:Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver;
aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.key:Ljava/lang/Object;
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.cancel:(Ljava/lang/Object;)V
4: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$State<TT;TK;>;
public boolean isDisposed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$State<TT;TK;>;
public void subscribe(io.reactivex.Observer<? super T>);
descriptor: (Lio/reactivex/Observer;)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.internal.operators.observable.ObservableGroupBy$State.once:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_0
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
ifeq 8
1: aload 1
aload 0
invokeinterface io.reactivex.Observer.onSubscribe:(Lio/reactivex/disposables/Disposable;)V
2: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.actual:Ljava/util/concurrent/atomic/AtomicReference;
aload 1
invokevirtual java.util.concurrent.atomic.AtomicReference.lazySet:(Ljava/lang/Object;)V
3: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ifeq 6
4: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.actual:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.lazySet:(Ljava/lang/Object;)V
5: goto 9
6: StackMap locals:
StackMap stack:
aload 0
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$State.drain:()V
7: goto 9
8: StackMap locals:
StackMap stack:
new java.lang.IllegalStateException
dup
ldc "Only one Observer allowed!"
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
aload 1
invokestatic io.reactivex.internal.disposables.EmptyDisposable.error:(Ljava/lang/Throwable;Lio/reactivex/Observer;)V
9: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$State<TT;TK;>;
0 10 1 observer Lio/reactivex/Observer<-TT;>;
Signature: (Lio/reactivex/Observer<-TT;>;)V
MethodParameters:
Name Flags
observer
public void onNext();
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
aload 1
invokevirtual io.reactivex.internal.queue.SpscLinkedArrayQueue.offer:(Ljava/lang/Object;)Z
pop
1: aload 0
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$State.drain:()V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$State<TT;TK;>;
0 3 1 t TT;
Signature: (TT;)V
MethodParameters:
Name Flags
t
public void onError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.error:Ljava/lang/Throwable;
1: aload 0
iconst_1
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.done:Z
2: aload 0
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$State.drain:()V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$State<TT;TK;>;
0 4 1 e Ljava/lang/Throwable;
MethodParameters:
Name Flags
e
public void onComplete();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_1
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.done:Z
1: aload 0
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$State.drain:()V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$State<TT;TK;>;
void drain();
descriptor: ()V
flags: (0x0000)
Code:
stack=5, locals=8, args_size=1
start local 0 0: aload 0
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$State.getAndIncrement:()I
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
iconst_1
istore 1
start local 1 3: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
astore 2
start local 2 4: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.delayError:Z
istore 3
start local 3 5: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.actual:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.reactivex.Observer
astore 4
start local 4 6: StackMap locals: io.reactivex.internal.operators.observable.ObservableGroupBy$State int io.reactivex.internal.queue.SpscLinkedArrayQueue int io.reactivex.Observer
StackMap stack:
aload 4
ifnull 18
7: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.done:Z
istore 5
start local 5 8: aload 2
invokevirtual io.reactivex.internal.queue.SpscLinkedArrayQueue.poll:()Ljava/lang/Object;
astore 6
start local 6 9: aload 6
ifnonnull 10
iconst_1
goto 11
StackMap locals: int java.lang.Object
StackMap stack:
10: iconst_0
StackMap locals:
StackMap stack: int
11: istore 7
start local 7 12: aload 0
iload 5
iload 7
aload 4
iload 3
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$State.checkTerminated:(ZZLio/reactivex/Observer;Z)Z
ifeq 14
13: return
14: StackMap locals: int
StackMap stack:
iload 7
ifeq 16
15: goto 18
16: StackMap locals:
StackMap stack:
aload 4
aload 6
invokeinterface io.reactivex.Observer.onNext:(Ljava/lang/Object;)V
end local 7 end local 6 end local 5 17: goto 7
18: StackMap locals:
StackMap stack:
aload 0
iload 1
ineg
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$State.addAndGet:(I)I
istore 1
19: iload 1
ifne 21
20: goto 24
21: StackMap locals:
StackMap stack:
aload 4
ifnonnull 6
22: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.actual:Ljava/util/concurrent/atomic/AtomicReference;
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast io.reactivex.Observer
astore 4
23: goto 6
24: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 25 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$State<TT;TK;>;
3 25 1 missed I
4 25 2 q Lio/reactivex/internal/queue/SpscLinkedArrayQueue<TT;>;
5 25 3 delayError Z
6 25 4 a Lio/reactivex/Observer<-TT;>;
8 17 5 d Z
9 17 6 v TT;
12 17 7 empty Z
boolean checkTerminated(boolean, boolean, io.reactivex.Observer<? super T>, );
descriptor: (ZZLio/reactivex/Observer;Z)Z
flags: (0x0000)
Code:
stack=2, locals=6, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ifeq 5
1: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invokevirtual io.reactivex.internal.queue.SpscLinkedArrayQueue.clear:()V
2: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.parent:Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver;
aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.key:Ljava/lang/Object;
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.cancel:(Ljava/lang/Object;)V
3: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.actual:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.lazySet:(Ljava/lang/Object;)V
4: iconst_1
ireturn
5: StackMap locals:
StackMap stack:
iload 1
ifeq 25
6: iload 4
ifeq 15
7: iload 2
ifeq 25
8: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.error:Ljava/lang/Throwable;
astore 5
start local 5 9: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.actual:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.lazySet:(Ljava/lang/Object;)V
10: aload 5
ifnull 13
11: aload 3
aload 5
invokeinterface io.reactivex.Observer.onError:(Ljava/lang/Throwable;)V
12: goto 14
13: StackMap locals: java.lang.Throwable
StackMap stack:
aload 3
invokeinterface io.reactivex.Observer.onComplete:()V
14: StackMap locals:
StackMap stack:
iconst_1
ireturn
end local 5 15: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.error:Ljava/lang/Throwable;
astore 5
start local 5 16: aload 5
ifnull 21
17: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.queue:Lio/reactivex/internal/queue/SpscLinkedArrayQueue;
invokevirtual io.reactivex.internal.queue.SpscLinkedArrayQueue.clear:()V
18: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.actual:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.lazySet:(Ljava/lang/Object;)V
19: aload 3
aload 5
invokeinterface io.reactivex.Observer.onError:(Ljava/lang/Throwable;)V
20: iconst_1
ireturn
21: StackMap locals: java.lang.Throwable
StackMap stack:
iload 2
ifeq 25
22: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$State.actual:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.lazySet:(Ljava/lang/Object;)V
23: aload 3
invokeinterface io.reactivex.Observer.onComplete:()V
24: iconst_1
ireturn
end local 5 25: StackMap locals:
StackMap stack:
iconst_0
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 26 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$State<TT;TK;>;
0 26 1 d Z
0 26 2 empty Z
0 26 3 a Lio/reactivex/Observer<-TT;>;
0 26 4 delayError Z
9 15 5 e Ljava/lang/Throwable;
16 25 5 e Ljava/lang/Throwable;
Signature: (ZZLio/reactivex/Observer<-TT;>;Z)Z
MethodParameters:
Name Flags
d
empty
a
delayError
}
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;>Ljava/util/concurrent/atomic/AtomicInteger;Lio/reactivex/disposables/Disposable;Lio/reactivex/ObservableSource<TT;>;
SourceFile: "ObservableGroupBy.java"
NestHost: io.reactivex.internal.operators.observable.ObservableGroupBy
InnerClasses:
public final GroupByObserver = io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver of io.reactivex.internal.operators.observable.ObservableGroupBy
final State = io.reactivex.internal.operators.observable.ObservableGroupBy$State of io.reactivex.internal.operators.observable.ObservableGroupBy