public class io.vertx.core.shareddata.impl.LocalAsyncMapImpl<K, V> implements io.vertx.core.shareddata.AsyncMap<K, V>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.core.shareddata.impl.LocalAsyncMapImpl
super_class: java.lang.Object
{
private final io.vertx.core.Vertx vertx;
descriptor: Lio/vertx/core/Vertx;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.ConcurrentMap<K, io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder<V>> map;
descriptor: Ljava/util/concurrent/ConcurrentMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/ConcurrentMap<TK;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;>;
public void <init>(io.vertx.core.Vertx);
descriptor: (Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
2: aload 0
new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
putfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 4 1 vertx Lio/vertx/core/Vertx;
MethodParameters:
Name Flags
vertx
public void get(K, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>);
descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokeinterface java.util.concurrent.ConcurrentMap.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
astore 3
start local 3 1: aload 3
ifnull 4
aload 3
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.hasNotExpired:()Z
ifeq 4
2: aload 2
aload 3
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: goto 5
4: StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
StackMap stack:
aload 2
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
5: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 6 1 k TK;
0 6 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;
1 6 3 h Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
Signature: (TK;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;)V
MethodParameters:
Name Flags
k final
resultHandler
public void put(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/Object;Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
aload 1
new io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
dup
aload 2
invokespecial io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.<init>:(Ljava/lang/Object;)V
invokeinterface java.util.concurrent.ConcurrentMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
astore 4
start local 4 1: aload 4
ifnull 3
aload 4
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
ifeq 3
2: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
aload 4
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.timerId:J
invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
pop
3: StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
StackMap stack:
aload 3
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
4: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 5 1 k TK;
0 5 2 v TV;
0 5 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 5 4 previous Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
Signature: (TK;TV;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
k final
v final
resultHandler
public void putIfAbsent(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>);
descriptor: (Ljava/lang/Object;Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
aload 1
new io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
dup
aload 2
invokespecial io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.<init>:(Ljava/lang/Object;)V
invokeinterface java.util.concurrent.ConcurrentMap.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
astore 4
start local 4 1: aload 3
aload 4
ifnonnull 2
aconst_null
goto 3
StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl java.lang.Object java.lang.Object io.vertx.core.Handler io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
StackMap stack: io.vertx.core.Handler
2: aload 4
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl java.lang.Object java.lang.Object io.vertx.core.Handler io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
StackMap stack: io.vertx.core.Handler java.lang.Object
3: invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
4: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 5 1 k TK;
0 5 2 v TV;
0 5 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;
1 5 4 h Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
Signature: (TK;TV;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;)V
MethodParameters:
Name Flags
k
v
resultHandler
public void put(K, V, long, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/Object;Ljava/lang/Object;JLio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=11, locals=11, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: invokestatic java.lang.System.nanoTime:()J
lstore 6
start local 6 1: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
lload 3
aload 0
aload 1
invokedynamic handle(Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl;Ljava/lang/Object;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/shareddata/impl/LocalAsyncMapImpl.lambda$0(Ljava/lang/Object;Ljava/lang/Long;)V (7)
(Ljava/lang/Long;)V
invokeinterface io.vertx.core.Vertx.setTimer:(JLio/vertx/core/Handler;)J
lstore 8
start local 8 2: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
aload 1
new io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
dup
aload 2
lload 8
lload 3
lload 6
invokespecial io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.<init>:(Ljava/lang/Object;JJJ)V
invokeinterface java.util.concurrent.ConcurrentMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
astore 10
start local 10 3: aload 10
ifnull 5
aload 10
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
ifeq 5
4: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
aload 10
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.timerId:J
invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
pop
5: StackMap locals: long long io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
StackMap stack:
aload 5
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
6: return
end local 10 end local 8 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 7 1 k TK;
0 7 2 v TV;
0 7 3 timeout J
0 7 5 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 7 6 timestamp J
2 7 8 timerId J
3 7 10 previous Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
Signature: (TK;TV;JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
k
v
timeout
completionHandler
private void removeIfExpired();
descriptor: (Ljava/lang/Object;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokedynamic apply()Ljava/util/function/BiFunction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/core/shareddata/impl/LocalAsyncMapImpl.lambda$1(Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder; (6)
(Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;
invokeinterface java.util.concurrent.ConcurrentMap.computeIfPresent:(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 2 1 k TK;
Signature: (TK;)V
MethodParameters:
Name Flags
k
public void putIfAbsent(K, V, long, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>);
descriptor: (Ljava/lang/Object;Ljava/lang/Object;JLio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=11, locals=11, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: invokestatic java.lang.System.nanoTime:()J
lstore 6
start local 6 1: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
lload 3
aload 0
aload 1
invokedynamic handle(Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl;Ljava/lang/Object;)Lio/vertx/core/Handler;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
io/vertx/core/shareddata/impl/LocalAsyncMapImpl.lambda$2(Ljava/lang/Object;Ljava/lang/Long;)V (7)
(Ljava/lang/Long;)V
invokeinterface io.vertx.core.Vertx.setTimer:(JLio/vertx/core/Handler;)J
lstore 8
start local 8 2: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
aload 1
new io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
dup
aload 2
lload 8
lload 3
lload 6
invokespecial io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.<init>:(Ljava/lang/Object;JJJ)V
invokeinterface java.util.concurrent.ConcurrentMap.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
astore 10
start local 10 3: aload 10
ifnull 8
4: aload 10
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
ifeq 6
5: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
lload 8
invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
pop
6: StackMap locals: long long io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
StackMap stack:
aload 5
aload 10
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
7: goto 9
8: StackMap locals:
StackMap stack:
aload 5
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
9: StackMap locals:
StackMap stack:
return
end local 10 end local 8 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 10 1 k TK;
0 10 2 v TV;
0 10 3 timeout J
0 10 5 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;
1 10 6 timestamp J
2 10 8 timerId J
3 10 10 existing Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
Signature: (TK;TV;JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;)V
MethodParameters:
Name Flags
k
v
timeout
completionHandler
public void removeIfPresent(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Boolean>>);
descriptor: (Ljava/lang/Object;Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: new java.util.concurrent.atomic.AtomicBoolean
dup
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:()V
astore 4
start local 4 1: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
aload 1
aload 0
aload 2
aload 4
invokedynamic apply(Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl;Ljava/lang/Object;Ljava/util/concurrent/atomic/AtomicBoolean;)Ljava/util/function/BiFunction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/core/shareddata/impl/LocalAsyncMapImpl.lambda$3(Ljava/lang/Object;Ljava/util/concurrent/atomic/AtomicBoolean;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder; (7)
(Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;
invokeinterface java.util.concurrent.ConcurrentMap.computeIfPresent:(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object;
pop
2: aload 3
aload 4
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 4 1 k TK;
0 4 2 v TV;
0 4 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Boolean;>;>;
1 4 4 result Ljava/util/concurrent/atomic/AtomicBoolean;
Signature: (TK;TV;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Boolean;>;>;)V
MethodParameters:
Name Flags
k
v
resultHandler
public void replace(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>);
descriptor: (Ljava/lang/Object;Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
aload 1
new io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
dup
aload 2
invokespecial io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.<init>:(Ljava/lang/Object;)V
invokeinterface java.util.concurrent.ConcurrentMap.replace:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
astore 4
start local 4 1: aload 4
ifnull 6
2: aload 4
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
ifeq 4
3: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
aload 4
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.timerId:J
invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
pop
4: StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
StackMap stack:
aload 3
aload 4
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
5: goto 7
6: StackMap locals:
StackMap stack:
aload 3
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
7: 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 8 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 8 1 k TK;
0 8 2 v TV;
0 8 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;
1 8 4 previous Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
Signature: (TK;TV;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;)V
MethodParameters:
Name Flags
k
v
resultHandler
public void replaceIfPresent(K, V, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Boolean>>);
descriptor: (Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=7, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
dup
aload 3
invokespecial io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.<init>:(Ljava/lang/Object;)V
astore 5
start local 5 1: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
aload 1
aload 0
aload 2
aload 5
invokedynamic apply(Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Ljava/util/function/BiFunction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/core/shareddata/impl/LocalAsyncMapImpl.lambda$4(Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder; (7)
(Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;
invokeinterface java.util.concurrent.ConcurrentMap.computeIfPresent:(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object;
checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
astore 6
start local 6 2: aload 4
aload 5
aload 6
if_acmpne 3
iconst_1
goto 4
StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl java.lang.Object java.lang.Object java.lang.Object io.vertx.core.Handler io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
StackMap stack: io.vertx.core.Handler
3: iconst_0
StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl java.lang.Object java.lang.Object java.lang.Object io.vertx.core.Handler io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
StackMap stack: io.vertx.core.Handler int
4: invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
5: 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 6 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 6 1 k TK;
0 6 2 oldValue TV;
0 6 3 newValue TV;
0 6 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Boolean;>;>;
1 6 5 h Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
2 6 6 result Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
Signature: (TK;TV;TV;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Boolean;>;>;)V
MethodParameters:
Name Flags
k
oldValue
newValue
resultHandler
public void clear(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.clear:()V
1: aload 1
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 3 1 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
resultHandler
public void size(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Integer>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.size:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 2 1 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Integer;>;>;)V
MethodParameters:
Name Flags
resultHandler
public void keys(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Set<K>>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 1
new java.util.HashSet
dup
aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.keySet:()Ljava/util/Set;
invokespecial java.util.HashSet.<init>:(Ljava/util/Collection;)V
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 2 1 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Set<TK;>;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Set<TK;>;>;>;)V
MethodParameters:
Name Flags
resultHandler
public void values(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<V>>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
1: invokedynamic test()Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
io/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder.hasNotExpired()Z (5)
(Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
2: invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/core/shareddata/impl/LocalAsyncMapImpl.lambda$6(Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Ljava/lang/Object; (6)
(Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Ljava/lang/Object;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
3: invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
4: astore 2
start local 2 5: aload 1
aload 2
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 7 1 asyncResultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<TV;>;>;>;
5 7 2 result Ljava/util/List<TV;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<TV;>;>;>;)V
MethodParameters:
Name Flags
asyncResultHandler
public void entries(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<K, V>>>);
descriptor: (Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: new java.util.HashMap
dup
aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
invokeinterface java.util.concurrent.ConcurrentMap.size:()I
invokespecial java.util.HashMap.<init>:(I)V
astore 2
start local 2 1: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
aload 2
invokedynamic accept(Ljava/util/Map;)Ljava/util/function/BiConsumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)V
io/vertx/core/shareddata/impl/LocalAsyncMapImpl.lambda$7(Ljava/util/Map;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)V (6)
(Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)V
invokeinterface java.util.concurrent.ConcurrentMap.forEach:(Ljava/util/function/BiConsumer;)V
2: aload 1
aload 2
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 4 1 asyncResultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<TK;TV;>;>;>;
1 4 2 result Ljava/util/Map<TK;TV;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<TK;TV;>;>;>;)V
MethodParameters:
Name Flags
asyncResultHandler
public void remove(K, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>);
descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.map:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokeinterface java.util.concurrent.ConcurrentMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
astore 3
start local 3 1: aload 3
ifnull 6
2: aload 3
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
ifeq 4
3: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
aload 3
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.timerId:J
invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
pop
4: StackMap locals: io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
StackMap stack:
aload 2
aload 3
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
invokestatic io.vertx.core.Future.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
5: goto 7
6: StackMap locals:
StackMap stack:
aload 2
invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
7: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 8 1 k TK;
0 8 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;
1 8 3 previous Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
Signature: (TK;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;)V
MethodParameters:
Name Flags
k final
resultHandler
private void lambda$0(java.lang.Object, java.lang.Long);
descriptor: (Ljava/lang/Object;Ljava/lang/Long;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl.removeIfExpired:(Ljava/lang/Object;)V
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 1 2 l Ljava/lang/Long;
private static io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder lambda$1(java.lang.Object, io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder);
descriptor: (Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.hasNotExpired:()Z
ifeq 1
aload 1
goto 2
StackMap locals:
StackMap stack:
1: aconst_null
StackMap locals:
StackMap stack: io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
2: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 key TK;
0 3 1 holder Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
private void lambda$2(java.lang.Object, java.lang.Long);
descriptor: (Ljava/lang/Object;Ljava/lang/Long;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 2 0: aload 0
aload 1
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl.removeIfExpired:(Ljava/lang/Object;)V
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 1 2 l Ljava/lang/Long;
private io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder lambda$3(java.lang.Object, java.util.concurrent.atomic.AtomicBoolean, java.lang.Object, io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder);
descriptor: (Ljava/lang/Object;Ljava/util/concurrent/atomic/AtomicBoolean;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=5, args_size=5
start local 0 start local 3 start local 4 0: aload 4
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
aload 1
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 5
1: aload 2
iconst_0
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
pop
2: aload 4
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
ifeq 4
3: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
aload 4
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.timerId:J
invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
pop
4: StackMap locals:
StackMap stack:
aconst_null
areturn
5: StackMap locals:
StackMap stack:
aload 4
areturn
end local 4 end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 6 3 key TK;
0 6 4 holder Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
private io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder lambda$4(java.lang.Object, io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder, java.lang.Object, io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder);
descriptor: (Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=5, args_size=5
start local 0 start local 3 start local 4 0: aload 4
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
aload 1
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 4
1: aload 4
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.expires:()Z
ifeq 3
2: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
aload 4
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.timerId:J
invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
pop
3: StackMap locals:
StackMap stack:
aload 2
areturn
4: StackMap locals:
StackMap stack:
aload 4
areturn
end local 4 end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl<TK;TV;>;
0 5 3 key TK;
0 5 4 holder Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
private static java.lang.Object lambda$6(io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder);
descriptor: (Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)Ljava/lang/Object;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 h Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
private static void lambda$7(java.util.Map, java.lang.Object, io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder);
descriptor: (Ljava/util/Map;Ljava/lang/Object;Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 1 start local 2 0: aload 2
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.hasNotExpired:()Z
ifeq 2
1: aload 0
aload 1
aload 2
getfield io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder.value:Ljava/lang/Object;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: StackMap locals:
StackMap stack:
return
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 3 1 key TK;
0 3 2 holder Lio/vertx/core/shareddata/impl/LocalAsyncMapImpl$Holder<TV;>;
}
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>Ljava/lang/Object;Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;
SourceFile: "LocalAsyncMapImpl.java"
NestMembers:
io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder
InnerClasses:
private Holder = io.vertx.core.shareddata.impl.LocalAsyncMapImpl$Holder of io.vertx.core.shareddata.impl.LocalAsyncMapImpl
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles