final class com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher extends com.google.common.eventbus.Dispatcher
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher
super_class: com.google.common.eventbus.Dispatcher
{
private final java.util.concurrent.ConcurrentLinkedQueue<com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber> queue;
descriptor: Ljava/util/concurrent/ConcurrentLinkedQueue;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/ConcurrentLinkedQueue<Lcom/google/common/eventbus/Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber;>;
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=1, args_size=1
start local 0 // com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher this
0: .line 130
aload 0 /* this */
invokespecial com.google.common.eventbus.Dispatcher.<init>:()V
1: .line 151
aload 0 /* this */
2: .line 152
invokestatic com.google.common.collect.Queues.newConcurrentLinkedQueue:()Ljava/util/concurrent/ConcurrentLinkedQueue;
putfield com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher.queue:Ljava/util/concurrent/ConcurrentLinkedQueue;
3: .line 130
return
end local 0 // com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher this
LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/google/common/eventbus/Dispatcher$LegacyAsyncDispatcher;
void dispatch(, java.util.Iterator<com.google.common.eventbus.Subscriber>);
descriptor: (Ljava/lang/Object;Ljava/util/Iterator;)V
flags: (0x0000)
Code:
stack=5, locals=4, args_size=3
start local 0 // com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher this
start local 1 // java.lang.Object event
start local 2 // java.util.Iterator subscribers
0: .line 156
aload 1 /* event */
invokestatic com.google.common.base.Preconditions.checkNotNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: .line 157
goto 3
2: .line 158
StackMap locals:
StackMap stack:
aload 0 /* this */
getfield com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher.queue:Ljava/util/concurrent/ConcurrentLinkedQueue;
new com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber
dup
aload 1 /* event */
aload 2 /* subscribers */
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast com.google.common.eventbus.Subscriber
invokespecial com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber.<init>:(Ljava/lang/Object;Lcom/google/common/eventbus/Subscriber;)V
invokevirtual java.util.concurrent.ConcurrentLinkedQueue.add:(Ljava/lang/Object;)Z
pop
3: .line 157
StackMap locals:
StackMap stack:
aload 2 /* subscribers */
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
4: .line 162
goto 6
start local 3 // com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber e
5: .line 163
StackMap locals: com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber
StackMap stack:
aload 3 /* e */
getfield com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber.subscriber:Lcom/google/common/eventbus/Subscriber;
aload 3 /* e */
getfield com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber.event:Ljava/lang/Object;
invokevirtual com.google.common.eventbus.Subscriber.dispatchEvent:(Ljava/lang/Object;)V
end local 3 // com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber e
6: .line 162
StackMap locals:
StackMap stack:
aload 0 /* this */
getfield com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher.queue:Ljava/util/concurrent/ConcurrentLinkedQueue;
invokevirtual java.util.concurrent.ConcurrentLinkedQueue.poll:()Ljava/lang/Object;
checkcast com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber
dup
astore 3 /* e */
start local 3 // com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber e
7: ifnonnull 5
8: .line 165
return
end local 3 // com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber e
end local 2 // java.util.Iterator subscribers
end local 1 // java.lang.Object event
end local 0 // com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher this
LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lcom/google/common/eventbus/Dispatcher$LegacyAsyncDispatcher;
0 9 1 event Ljava/lang/Object;
0 9 2 subscribers Ljava/util/Iterator<Lcom/google/common/eventbus/Subscriber;>;
5 6 3 e Lcom/google/common/eventbus/Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber;
7 9 3 e Lcom/google/common/eventbus/Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber;
Signature: (Ljava/lang/Object;Ljava/util/Iterator<Lcom/google/common/eventbus/Subscriber;>;)V
MethodParameters:
Name Flags
event
subscribers
}
SourceFile: "Dispatcher.java"
NestHost: com.google.common.eventbus.Dispatcher
InnerClasses:
private final LegacyAsyncDispatcher = com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher of com.google.common.eventbus.Dispatcher
private final EventWithSubscriber = com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher$EventWithSubscriber of com.google.common.eventbus.Dispatcher$LegacyAsyncDispatcher