public final class io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver<T, K, V> extends java.util.concurrent.atomic.AtomicInteger implements io.reactivex.Observer<T>, io.reactivex.disposables.Disposable
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver
super_class: java.util.concurrent.atomic.AtomicInteger
{
private static final long serialVersionUID;
descriptor: J
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: -3688291656102519502
final io.reactivex.Observer<? super io.reactivex.observables.GroupedObservable<K, V>> downstream;
descriptor: Lio/reactivex/Observer;
flags: (0x0010) ACC_FINAL
Signature: Lio/reactivex/Observer<-Lio/reactivex/observables/GroupedObservable<TK;TV;>;>;
final io.reactivex.functions.Function<? super T, ? extends K> keySelector;
descriptor: Lio/reactivex/functions/Function;
flags: (0x0010) ACC_FINAL
Signature: Lio/reactivex/functions/Function<-TT;+TK;>;
final io.reactivex.functions.Function<? super T, ? extends V> valueSelector;
descriptor: Lio/reactivex/functions/Function;
flags: (0x0010) ACC_FINAL
Signature: Lio/reactivex/functions/Function<-TT;+TV;>;
final int bufferSize;
descriptor: I
flags: (0x0010) ACC_FINAL
final boolean delayError;
descriptor: Z
flags: (0x0010) ACC_FINAL
final java.util.Map<java.lang.Object, io.reactivex.internal.operators.observable.ObservableGroupBy$GroupedUnicast<K, V>> groups;
descriptor: Ljava/util/Map;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/Object;Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupedUnicast<TK;TV;>;>;
static final java.lang.Object NULL_KEY;
descriptor: Ljava/lang/Object;
flags: (0x0018) ACC_STATIC, ACC_FINAL
io.reactivex.disposables.Disposable upstream;
descriptor: Lio/reactivex/disposables/Disposable;
flags: (0x0000)
final java.util.concurrent.atomic.AtomicBoolean cancelled;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0010) ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: new java.lang.Object
dup
invokespecial java.lang.Object.<init>:()V
putstatic io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.NULL_KEY:Ljava/lang/Object;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.reactivex.Observer<? super io.reactivex.observables.GroupedObservable<K, V>>, io.reactivex.functions.Function<? super T, ? extends K>, io.reactivex.functions.Function<? super T, ? extends V>, int, );
descriptor: (Lio/reactivex/Observer;Lio/reactivex/functions/Function;Lio/reactivex/functions/Function;IZ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 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$GroupByObserver.cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
2: aload 0
aload 1
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.downstream:Lio/reactivex/Observer;
3: aload 0
aload 2
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.keySelector:Lio/reactivex/functions/Function;
4: aload 0
aload 3
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.valueSelector:Lio/reactivex/functions/Function;
5: aload 0
iload 4
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.bufferSize:I
6: aload 0
iload 5
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.delayError:Z
7: aload 0
new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.groups:Ljava/util/Map;
8: aload 0
iconst_1
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.lazySet:(I)V
9: return
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 10 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver<TT;TK;TV;>;
0 10 1 actual Lio/reactivex/Observer<-Lio/reactivex/observables/GroupedObservable<TK;TV;>;>;
0 10 2 keySelector Lio/reactivex/functions/Function<-TT;+TK;>;
0 10 3 valueSelector Lio/reactivex/functions/Function<-TT;+TV;>;
0 10 4 bufferSize I
0 10 5 delayError Z
Signature: (Lio/reactivex/Observer<-Lio/reactivex/observables/GroupedObservable<TK;TV;>;>;Lio/reactivex/functions/Function<-TT;+TK;>;Lio/reactivex/functions/Function<-TT;+TV;>;IZ)V
MethodParameters:
Name Flags
actual
keySelector
valueSelector
bufferSize
delayError
public void onSubscribe(io.reactivex.disposables.Disposable);
descriptor: (Lio/reactivex/disposables/Disposable;)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$GroupByObserver.upstream:Lio/reactivex/disposables/Disposable;
aload 1
invokestatic io.reactivex.internal.disposables.DisposableHelper.validate:(Lio/reactivex/disposables/Disposable;Lio/reactivex/disposables/Disposable;)Z
ifeq 3
1: aload 0
aload 1
putfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.upstream:Lio/reactivex/disposables/Disposable;
2: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.downstream:Lio/reactivex/Observer;
aload 0
invokeinterface io.reactivex.Observer.onSubscribe:(Lio/reactivex/disposables/Disposable;)V
3: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver<TT;TK;TV;>;
0 4 1 d Lio/reactivex/disposables/Disposable;
MethodParameters:
Name Flags
d
public void onNext();
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=7, args_size=2
start local 0 start local 1 0: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.keySelector:Lio/reactivex/functions/Function;
aload 1
invokeinterface io.reactivex.functions.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
astore 2
start local 2 1: goto 7
end local 2 StackMap locals:
StackMap stack: java.lang.Throwable
2: astore 3
start local 3 3: aload 3
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
4: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.upstream:Lio/reactivex/disposables/Disposable;
invokeinterface io.reactivex.disposables.Disposable.dispose:()V
5: aload 0
aload 3
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.onError:(Ljava/lang/Throwable;)V
6: return
end local 3 start local 2 7: StackMap locals: java.lang.Object
StackMap stack:
aload 2
ifnull 8
aload 2
goto 9
StackMap locals:
StackMap stack:
8: getstatic io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.NULL_KEY:Ljava/lang/Object;
StackMap locals:
StackMap stack: java.lang.Object
9: astore 3
start local 3 10: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.groups:Ljava/util/Map;
aload 3
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.reactivex.internal.operators.observable.ObservableGroupBy$GroupedUnicast
astore 4
start local 4 11: aload 4
ifnonnull 18
12: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ifeq 14
13: return
14: StackMap locals: java.lang.Object io.reactivex.internal.operators.observable.ObservableGroupBy$GroupedUnicast
StackMap stack:
aload 2
aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.bufferSize:I
aload 0
aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.delayError:Z
invokestatic io.reactivex.internal.operators.observable.ObservableGroupBy$GroupedUnicast.createWith:(Ljava/lang/Object;ILio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver;Z)Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupedUnicast;
astore 4
15: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.groups:Ljava/util/Map;
aload 3
aload 4
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
16: aload 0
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.getAndIncrement:()I
pop
17: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.downstream:Lio/reactivex/Observer;
aload 4
invokeinterface io.reactivex.Observer.onNext:(Ljava/lang/Object;)V
18: StackMap locals:
StackMap stack:
aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.valueSelector:Lio/reactivex/functions/Function;
aload 1
invokeinterface io.reactivex.functions.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
ldc "The value supplied is null"
invokestatic io.reactivex.internal.functions.ObjectHelper.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
astore 5
start local 5 19: goto 25
end local 5 StackMap locals:
StackMap stack: java.lang.Throwable
20: astore 6
start local 6 21: aload 6
invokestatic io.reactivex.exceptions.Exceptions.throwIfFatal:(Ljava/lang/Throwable;)V
22: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.upstream:Lio/reactivex/disposables/Disposable;
invokeinterface io.reactivex.disposables.Disposable.dispose:()V
23: aload 0
aload 6
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.onError:(Ljava/lang/Throwable;)V
24: return
end local 6 start local 5 25: StackMap locals: java.lang.Object
StackMap stack:
aload 4
aload 5
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$GroupedUnicast.onNext:(Ljava/lang/Object;)V
26: return
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 27 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver<TT;TK;TV;>;
0 27 1 t TT;
1 2 2 key TK;
7 27 2 key TK;
3 7 3 e Ljava/lang/Throwable;
10 27 3 mapKey Ljava/lang/Object;
11 27 4 group Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupedUnicast<TK;TV;>;
19 20 5 v TV;
25 27 5 v TV;
21 25 6 e Ljava/lang/Throwable;
Exception table:
from to target type
0 1 2 Class java.lang.Throwable
18 19 20 Class java.lang.Throwable
Signature: (TT;)V
MethodParameters:
Name Flags
t
public void onError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: new java.util.ArrayList
dup
aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.groups:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
astore 2
start local 2 1: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.groups:Ljava/util/Map;
invokeinterface java.util.Map.clear:()V
2: aload 2
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 4
goto 5
StackMap locals: io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver java.lang.Throwable java.util.List top java.util.Iterator
StackMap stack:
3: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.reactivex.internal.operators.observable.ObservableGroupBy$GroupedUnicast
astore 3
start local 3 4: aload 3
aload 1
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$GroupedUnicast.onError:(Ljava/lang/Throwable;)V
end local 3 5: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
6: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.downstream:Lio/reactivex/Observer;
aload 1
invokeinterface io.reactivex.Observer.onError:(Ljava/lang/Throwable;)V
7: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver<TT;TK;TV;>;
0 8 1 t Ljava/lang/Throwable;
1 8 2 list Ljava/util/List<Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupedUnicast<TK;TV;>;>;
4 5 3 e Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupedUnicast<TK;TV;>;
MethodParameters:
Name Flags
t
public void onComplete();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=1
start local 0 0: new java.util.ArrayList
dup
aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.groups:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
astore 1
start local 1 1: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.groups:Ljava/util/Map;
invokeinterface java.util.Map.clear:()V
2: aload 1
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 5
StackMap locals: io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver java.util.List top java.util.Iterator
StackMap stack:
3: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast io.reactivex.internal.operators.observable.ObservableGroupBy$GroupedUnicast
astore 2
start local 2 4: aload 2
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$GroupedUnicast.onComplete:()V
end local 2 5: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
6: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.downstream:Lio/reactivex/Observer;
invokeinterface io.reactivex.Observer.onComplete:()V
7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver<TT;TK;TV;>;
1 8 1 list Ljava/util/List<Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupedUnicast<TK;TV;>;>;
4 5 2 e Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupedUnicast<TK;TV;>;
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$GroupByObserver.cancelled:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_0
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
ifeq 3
1: aload 0
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.decrementAndGet:()I
ifne 3
2: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.upstream:Lio/reactivex/disposables/Disposable;
invokeinterface io.reactivex.disposables.Disposable.dispose:()V
3: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver<TT;TK;TV;>;
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$GroupByObserver.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$GroupByObserver<TT;TK;TV;>;
public void cancel();
descriptor: (Ljava/lang/Object;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ifnull 1
aload 1
goto 2
StackMap locals:
StackMap stack:
1: getstatic io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.NULL_KEY:Ljava/lang/Object;
StackMap locals:
StackMap stack: java.lang.Object
2: astore 2
start local 2 3: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.groups:Ljava/util/Map;
aload 2
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 0
invokevirtual io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.decrementAndGet:()I
ifne 6
5: aload 0
getfield io.reactivex.internal.operators.observable.ObservableGroupBy$GroupByObserver.upstream:Lio/reactivex/disposables/Disposable;
invokeinterface io.reactivex.disposables.Disposable.dispose:()V
6: StackMap locals: java.lang.Object
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/reactivex/internal/operators/observable/ObservableGroupBy$GroupByObserver<TT;TK;TV;>;
0 7 1 key TK;
3 7 2 mapKey Ljava/lang/Object;
Signature: (TK;)V
MethodParameters:
Name Flags
key
}
Signature: <T:Ljava/lang/Object;K:Ljava/lang/Object;V:Ljava/lang/Object;>Ljava/util/concurrent/atomic/AtomicInteger;Lio/reactivex/Observer<TT;>;Lio/reactivex/disposables/Disposable;
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 GroupedUnicast = io.reactivex.internal.operators.observable.ObservableGroupBy$GroupedUnicast of io.reactivex.internal.operators.observable.ObservableGroupBy