class io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue$SerializedTask<U> implements io.vertx.core.Handler<io.vertx.core.AsyncResult<U>>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue$SerializedTask
super_class: java.lang.Object
{
final io.vertx.core.eventbus.Message<?> msg;
descriptor: Lio/vertx/core/eventbus/Message;
flags: (0x0010) ACC_FINAL
Signature: Lio/vertx/core/eventbus/Message<*>;
final java.util.function.BiConsumer<io.vertx.core.eventbus.Message<?>, io.vertx.core.Promise<U>> selectHandler;
descriptor: Ljava/util/function/BiConsumer;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/function/BiConsumer<Lio/vertx/core/eventbus/Message<*>;Lio/vertx/core/Promise<TU;>;>;
final io.vertx.core.Promise<U> internalPromise;
descriptor: Lio/vertx/core/Promise;
flags: (0x0010) ACC_FINAL
Signature: Lio/vertx/core/Promise<TU;>;
final io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue this$1;
descriptor: Lio/vertx/core/eventbus/impl/clustered/Serializer$SerializerQueue;
flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC
void <init>(io.vertx.core.impl.ContextInternal, io.vertx.core.eventbus.Message<?>, java.util.function.BiConsumer<io.vertx.core.eventbus.Message<?>, io.vertx.core.Promise<U>>);
descriptor: (Lio/vertx/core/eventbus/impl/clustered/Serializer$SerializerQueue;Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/eventbus/Message;Ljava/util/function/BiConsumer;)V
flags: (0x0000)
Code:
stack=2, locals=5, args_size=5
start local 0 start local 2 start local 3 start local 4 0: aload 0
aload 1
putfield io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue$SerializedTask.this$1:Lio/vertx/core/eventbus/impl/clustered/Serializer$SerializerQueue;
1: aload 0
invokespecial java.lang.Object.<init>:()V
2: aload 0
aload 3
putfield io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue$SerializedTask.msg:Lio/vertx/core/eventbus/Message;
3: aload 0
aload 4
putfield io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue$SerializedTask.selectHandler:Ljava/util/function/BiConsumer;
4: aload 0
aload 2
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
putfield io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue$SerializedTask.internalPromise:Lio/vertx/core/Promise;
5: return
end local 4 end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/eventbus/impl/clustered/Serializer$SerializerQueue$SerializedTask<TU;>;
0 6 2 context Lio/vertx/core/impl/ContextInternal;
0 6 3 msg Lio/vertx/core/eventbus/Message<*>;
0 6 4 selectHandler Ljava/util/function/BiConsumer<Lio/vertx/core/eventbus/Message<*>;Lio/vertx/core/Promise<TU;>;>;
Signature: (Lio/vertx/core/impl/ContextInternal;Lio/vertx/core/eventbus/Message<*>;Ljava/util/function/BiConsumer<Lio/vertx/core/eventbus/Message<*>;Lio/vertx/core/Promise<TU;>;>;)V
MethodParameters:
Name Flags
this$0 final
context
msg
selectHandler
void process();
descriptor: ()V
flags: (0x0000)
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue$SerializedTask.selectHandler:Ljava/util/function/BiConsumer;
aload 0
getfield io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue$SerializedTask.msg:Lio/vertx/core/eventbus/Message;
aload 0
getfield io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue$SerializedTask.internalPromise:Lio/vertx/core/Promise;
invokeinterface java.util.function.BiConsumer.accept:(Ljava/lang/Object;Ljava/lang/Object;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/eventbus/impl/clustered/Serializer$SerializerQueue$SerializedTask<TU;>;
public void handle(io.vertx.core.AsyncResult<U>);
descriptor: (Lio/vertx/core/AsyncResult;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue$SerializedTask.this$1:Lio/vertx/core/eventbus/impl/clustered/Serializer$SerializerQueue;
invokevirtual io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue.processed:()V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/eventbus/impl/clustered/Serializer$SerializerQueue$SerializedTask<TU;>;
0 2 1 ar Lio/vertx/core/AsyncResult<TU;>;
Signature: (Lio/vertx/core/AsyncResult<TU;>;)V
MethodParameters:
Name Flags
ar
public void handle(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast io.vertx.core.AsyncResult
invokevirtual io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue$SerializedTask.handle:(Lio/vertx/core/AsyncResult;)V
return
LocalVariableTable:
Start End Slot Name Signature
}
Signature: <U:Ljava/lang/Object;>Ljava/lang/Object;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TU;>;>;
SourceFile: "Serializer.java"
NestHost: io.vertx.core.eventbus.impl.clustered.Serializer
InnerClasses:
private SerializerQueue = io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue of io.vertx.core.eventbus.impl.clustered.Serializer
private SerializedTask = io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue$SerializedTask of io.vertx.core.eventbus.impl.clustered.Serializer$SerializerQueue