public class io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl<K, V> implements io.vertx.core.shareddata.AsyncMap<K, V>, io.vertx.ext.cluster.infinispan.InfinispanAsyncMap<K, V>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl
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 org.infinispan.AdvancedCache<java.lang.Object, java.lang.Object> cache;
descriptor: Lorg/infinispan/AdvancedCache;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lorg/infinispan/AdvancedCache<Ljava/lang/Object;Ljava/lang/Object;>;
public void <init>(io.vertx.core.Vertx, org.infinispan.Cache<java.lang.Object, java.lang.Object>);
descriptor: (Lio/vertx/core/Vertx;Lorg/infinispan/Cache;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
2: aload 0
aload 2
invokeinterface org.infinispan.Cache.getAdvancedCache:()Lorg/infinispan/AdvancedCache;
putfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 4 1 vertx Lio/vertx/core/Vertx;
0 4 2 cache Lorg/infinispan/Cache<Ljava/lang/Object;Ljava/lang/Object;>;
Signature: (Lio/vertx/core/Vertx;Lorg/infinispan/Cache<Ljava/lang/Object;Ljava/lang/Object;>;)V
MethodParameters:
Name Flags
vertx
cache
private <T> void whenComplete(java.util.concurrent.CompletableFuture<T>, io.vertx.core.Promise<T>);
descriptor: (Ljava/util/concurrent/CompletableFuture;Lio/vertx/core/Promise;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
astore 3
start local 3 1: aload 1
aload 3
aload 2
invokedynamic accept(Lio/vertx/core/Context;Lio/vertx/core/Promise;)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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$0(Lio/vertx/core/Context;Lio/vertx/core/Promise;Ljava/lang/Object;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Object;Ljava/lang/Throwable;)V
invokevirtual java.util.concurrent.CompletableFuture.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletableFuture;
pop
2: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 3 1 completableFuture Ljava/util/concurrent/CompletableFuture<TT;>;
0 3 2 future Lio/vertx/core/Promise<TT;>;
1 3 3 context Lio/vertx/core/Context;
Signature: <T:Ljava/lang/Object;>(Ljava/util/concurrent/CompletableFuture<TT;>;Lio/vertx/core/Promise<TT;>;)V
MethodParameters:
Name Flags
completableFuture
future
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=3, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 3
start local 3 1: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 4
start local 4 2: aload 4
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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/ext/cluster/infinispan/impl/DataConverter.fromCachedObject(Ljava/lang/Object;)Ljava/lang/Object; (6)
(Ljava/lang/Object;)Ljava/lang/Object;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: aload 0
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
aload 3
invokeinterface org.infinispan.AdvancedCache.getAsync:(Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
aload 4
invokevirtual io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.whenComplete:(Ljava/util/concurrent/CompletableFuture;Lio/vertx/core/Promise;)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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 5 1 k TK;
0 5 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;
1 5 3 kk Ljava/lang/Object;
2 5 4 vertxPromise Lio/vertx/core/Promise<Ljava/lang/Object;>;
Signature: (TK;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;)V
MethodParameters:
Name Flags
k
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=6, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 4
start local 4 1: aload 2
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 5
start local 5 2: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 6
start local 6 3: aload 6
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aconst_null
invokeinterface io.vertx.core.Future.map:(Ljava/lang/Object;)Lio/vertx/core/Future;
aload 3
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
4: aload 0
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
iconst_1
anewarray org.infinispan.context.Flag
dup
iconst_0
getstatic org.infinispan.context.Flag.IGNORE_RETURN_VALUES:Lorg/infinispan/context/Flag;
aastore
invokeinterface org.infinispan.AdvancedCache.withFlags:([Lorg/infinispan/context/Flag;)Lorg/infinispan/AdvancedCache;
aload 4
aload 5
invokeinterface org.infinispan.AdvancedCache.putAsync:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
aload 6
invokevirtual io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.whenComplete:(Ljava/util/concurrent/CompletableFuture;Lio/vertx/core/Promise;)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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 6 1 k TK;
0 6 2 v TV;
0 6 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 6 4 kk Ljava/lang/Object;
2 6 5 vv Ljava/lang/Object;
3 6 6 vertxPromise Lio/vertx/core/Promise<Ljava/lang/Object;>;
Signature: (TK;TV;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
k
v
completionHandler
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=7, locals=9, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: aload 1
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 6
start local 6 1: aload 2
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 7
start local 7 2: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 8
start local 8 3: aload 8
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aconst_null
invokeinterface io.vertx.core.Future.map:(Ljava/lang/Object;)Lio/vertx/core/Future;
aload 5
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
4: aload 0
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
iconst_1
anewarray org.infinispan.context.Flag
dup
iconst_0
getstatic org.infinispan.context.Flag.IGNORE_RETURN_VALUES:Lorg/infinispan/context/Flag;
aastore
invokeinterface org.infinispan.AdvancedCache.withFlags:([Lorg/infinispan/context/Flag;)Lorg/infinispan/AdvancedCache;
aload 6
aload 7
lload 3
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface org.infinispan.AdvancedCache.putAsync:(Ljava/lang/Object;Ljava/lang/Object;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/CompletableFuture;
aload 8
invokevirtual io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.whenComplete:(Ljava/util/concurrent/CompletableFuture;Lio/vertx/core/Promise;)V
5: return
end local 8 end local 7 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 6 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 6 1 k TK;
0 6 2 v TV;
0 6 3 ttl J
0 6 5 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 6 6 kk Ljava/lang/Object;
2 6 7 vv Ljava/lang/Object;
3 6 8 vertxPromise Lio/vertx/core/Promise<Ljava/lang/Object;>;
Signature: (TK;TV;JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
k
v
ttl
completionHandler
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=4, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 4
start local 4 1: aload 2
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 5
start local 5 2: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 6
start local 6 3: aload 6
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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/ext/cluster/infinispan/impl/DataConverter.fromCachedObject(Ljava/lang/Object;)Ljava/lang/Object; (6)
(Ljava/lang/Object;)Ljava/lang/Object;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
aload 3
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
4: aload 0
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
aload 4
aload 5
invokeinterface org.infinispan.AdvancedCache.putIfAbsentAsync:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
aload 6
invokevirtual io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.whenComplete:(Ljava/util/concurrent/CompletableFuture;Lio/vertx/core/Promise;)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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 6 1 k TK;
0 6 2 v TV;
0 6 3 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;
1 6 4 kk Ljava/lang/Object;
2 6 5 vv Ljava/lang/Object;
3 6 6 vertxPromise Lio/vertx/core/Promise<Ljava/lang/Object;>;
Signature: (TK;TV;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;)V
MethodParameters:
Name Flags
k
v
completionHandler
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=7, locals=9, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: aload 1
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 6
start local 6 1: aload 2
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 7
start local 7 2: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 8
start local 8 3: aload 8
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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/ext/cluster/infinispan/impl/DataConverter.fromCachedObject(Ljava/lang/Object;)Ljava/lang/Object; (6)
(Ljava/lang/Object;)Ljava/lang/Object;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
aload 5
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
4: aload 0
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
aload 6
aload 7
lload 3
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface org.infinispan.AdvancedCache.putIfAbsentAsync:(Ljava/lang/Object;Ljava/lang/Object;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/CompletableFuture;
aload 8
invokevirtual io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.whenComplete:(Ljava/util/concurrent/CompletableFuture;Lio/vertx/core/Promise;)V
5: return
end local 8 end local 7 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 6 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 6 1 k TK;
0 6 2 v TV;
0 6 3 ttl J
0 6 5 completionHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;
1 6 6 kk Ljava/lang/Object;
2 6 7 vv Ljava/lang/Object;
3 6 8 vertxPromise Lio/vertx/core/Promise<Ljava/lang/Object;>;
Signature: (TK;TV;JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;)V
MethodParameters:
Name Flags
k
v
ttl
completionHandler
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=5, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 3
start local 3 1: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 4
start local 4 2: aload 4
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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/ext/cluster/infinispan/impl/DataConverter.fromCachedObject(Ljava/lang/Object;)Ljava/lang/Object; (6)
(Ljava/lang/Object;)Ljava/lang/Object;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
aload 2
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
3: aload 0
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
aload 3
invokeinterface org.infinispan.AdvancedCache.removeAsync:(Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
aload 4
invokevirtual io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.whenComplete:(Ljava/util/concurrent/CompletableFuture;Lio/vertx/core/Promise;)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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 5 1 k TK;
0 5 2 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;
1 5 3 kk Ljava/lang/Object;
2 5 4 vertxPromise Lio/vertx/core/Promise<Ljava/lang/Object;>;
Signature: (TK;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;)V
MethodParameters:
Name Flags
k
resultHandler
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=4, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 4
start local 4 1: aload 2
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 5
start local 5 2: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 6
start local 6 3: aload 6
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 3
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
4: aload 0
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
aload 4
aload 5
invokeinterface org.infinispan.AdvancedCache.removeAsync:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
aload 6
invokevirtual io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.whenComplete:(Ljava/util/concurrent/CompletableFuture;Lio/vertx/core/Promise;)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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 6 1 k TK;
0 6 2 v TV;
0 6 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Boolean;>;>;
1 6 4 kk Ljava/lang/Object;
2 6 5 vv Ljava/lang/Object;
3 6 6 vertxPromise Lio/vertx/core/Promise<Ljava/lang/Boolean;>;
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=4, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 4
start local 4 1: aload 2
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 5
start local 5 2: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 6
start local 6 3: aload 6
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
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/ext/cluster/infinispan/impl/DataConverter.fromCachedObject(Ljava/lang/Object;)Ljava/lang/Object; (6)
(Ljava/lang/Object;)Ljava/lang/Object;
invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
aload 3
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
4: aload 0
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
aload 4
aload 5
invokeinterface org.infinispan.AdvancedCache.replaceAsync:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
aload 6
invokevirtual io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.whenComplete:(Ljava/util/concurrent/CompletableFuture;Lio/vertx/core/Promise;)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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 6 1 k TK;
0 6 2 v TV;
0 6 3 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TV;>;>;
1 6 4 kk Ljava/lang/Object;
2 6 5 vv Ljava/lang/Object;
3 6 6 vertxPromise Lio/vertx/core/Promise<Ljava/lang/Object;>;
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=9, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: aload 1
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 5
start local 5 1: aload 2
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 6
start local 6 2: aload 3
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 7
start local 7 3: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 8
start local 8 4: aload 8
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 4
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
5: aload 0
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
aload 5
aload 6
aload 7
invokeinterface org.infinispan.AdvancedCache.replaceAsync:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
aload 8
invokevirtual io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.whenComplete:(Ljava/util/concurrent/CompletableFuture;Lio/vertx/core/Promise;)V
6: return
end local 8 end local 7 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 7 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 7 1 k TK;
0 7 2 oldValue TV;
0 7 3 newValue TV;
0 7 4 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Boolean;>;>;
1 7 5 kk Ljava/lang/Object;
2 7 6 oo Ljava/lang/Object;
3 7 7 nn Ljava/lang/Object;
4 7 8 vertxPromise Lio/vertx/core/Promise<Ljava/lang/Boolean;>;
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=3, locals=3, args_size=2
start local 0 start local 1 0: invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
astore 2
start local 2 1: aload 2
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
aload 1
invokeinterface io.vertx.core.Future.setHandler:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
pop
2: aload 0
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
invokeinterface org.infinispan.AdvancedCache.clearAsync:()Ljava/util/concurrent/CompletableFuture;
aload 2
invokevirtual io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.whenComplete:(Ljava/util/concurrent/CompletableFuture;Lio/vertx/core/Promise;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 4 1 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 4 2 vertxPromise Lio/vertx/core/Promise<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=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
aload 0
invokedynamic handle(Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl;)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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$8(Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
iconst_0
aload 1
invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<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 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
aload 0
invokedynamic handle(Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl;)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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$9(Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
aload 1
2: invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 4 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=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
aload 0
invokedynamic handle(Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl;)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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$12(Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
aload 1
2: invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 4 1 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<TV;>;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<TV;>;>;>;)V
MethodParameters:
Name Flags
resultHandler
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=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
aload 0
invokedynamic handle(Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl;)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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$15(Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: iconst_0
aload 1
2: invokeinterface io.vertx.core.Vertx.executeBlocking:(Lio/vertx/core/Handler;ZLio/vertx/core/Handler;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 4 1 resultHandler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<TK;TV;>;>;>;
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/Map<TK;TV;>;>;>;)V
MethodParameters:
Name Flags
resultHandler
public io.vertx.core.streams.ReadStream<K> keyStream();
descriptor: ()Lio/vertx/core/streams/ReadStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: new io.vertx.ext.cluster.infinispan.impl.CloseableIteratorCollectionStream
dup
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic get(Lorg/infinispan/AdvancedCache;)Ljava/util/function/Supplier;
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;
org/infinispan/Cache.keySet()Lorg/infinispan/CacheSet; (9 itf)
()Lorg/infinispan/commons/util/CloseableIteratorCollection;
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/ext/cluster/infinispan/impl/DataConverter.fromCachedObject(Ljava/lang/Object;)Ljava/lang/Object; (6)
(Ljava/lang/Object;)Ljava/lang/Object;
invokespecial io.vertx.ext.cluster.infinispan.impl.CloseableIteratorCollectionStream.<init>:(Lio/vertx/core/Context;Ljava/util/function/Supplier;Ljava/util/function/Function;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
Signature: ()Lio/vertx/core/streams/ReadStream<TK;>;
public io.vertx.core.streams.ReadStream<V> valueStream();
descriptor: ()Lio/vertx/core/streams/ReadStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: new io.vertx.ext.cluster.infinispan.impl.CloseableIteratorCollectionStream
dup
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic get(Lorg/infinispan/AdvancedCache;)Ljava/util/function/Supplier;
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;
org/infinispan/Cache.values()Lorg/infinispan/CacheCollection; (9 itf)
()Lorg/infinispan/commons/util/CloseableIteratorCollection;
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/ext/cluster/infinispan/impl/DataConverter.fromCachedObject(Ljava/lang/Object;)Ljava/lang/Object; (6)
(Ljava/lang/Object;)Ljava/lang/Object;
invokespecial io.vertx.ext.cluster.infinispan.impl.CloseableIteratorCollectionStream.<init>:(Lio/vertx/core/Context;Ljava/util/function/Supplier;Ljava/util/function/Function;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
Signature: ()Lio/vertx/core/streams/ReadStream<TV;>;
public io.vertx.core.streams.ReadStream<java.util.Map$Entry<K, V>> entryStream();
descriptor: ()Lio/vertx/core/streams/ReadStream;
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: new io.vertx.ext.cluster.infinispan.impl.CloseableIteratorCollectionStream
dup
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.vertx:Lio/vertx/core/Vertx;
invokeinterface io.vertx.core.Vertx.getOrCreateContext:()Lio/vertx/core/Context;
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic get(Lorg/infinispan/AdvancedCache;)Ljava/util/function/Supplier;
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;
org/infinispan/Cache.entrySet()Lorg/infinispan/CacheSet; (9 itf)
()Lorg/infinispan/commons/util/CloseableIteratorCollection;
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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$24(Ljava/util/Map$Entry;)Ljava/util/Map$Entry; (6)
(Ljava/util/Map$Entry;)Ljava/util/Map$Entry;
invokespecial io.vertx.ext.cluster.infinispan.impl.CloseableIteratorCollectionStream.<init>:(Lio/vertx/core/Context;Ljava/util/function/Supplier;Ljava/util/function/Function;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
Signature: ()Lio/vertx/core/streams/ReadStream<Ljava/util/Map$Entry<TK;TV;>;>;
private static void lambda$0(io.vertx.core.Context, io.vertx.core.Promise, java.lang.Object, java.lang.Throwable);
descriptor: (Lio/vertx/core/Context;Lio/vertx/core/Promise;Ljava/lang/Object;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=4
start local 2 start local 3 0: aload 3
ifnull 3
1: aload 0
aload 1
aload 3
invokedynamic handle(Lio/vertx/core/Promise;Ljava/lang/Throwable;)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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$1(Lio/vertx/core/Promise;Ljava/lang/Throwable;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
2: goto 4
3: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 2
invokedynamic handle(Lio/vertx/core/Promise;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/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$2(Lio/vertx/core/Promise;Ljava/lang/Object;Ljava/lang/Void;)V (6)
(Ljava/lang/Void;)V
invokeinterface io.vertx.core.Context.runOnContext:(Lio/vertx/core/Handler;)V
4: StackMap locals:
StackMap stack:
return
end local 3 end local 2 LocalVariableTable:
Start End Slot Name Signature
0 5 2 v TT;
0 5 3 t Ljava/lang/Throwable;
private void lambda$8(io.vertx.core.Promise);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
invokeinterface org.infinispan.AdvancedCache.size:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 1 1 future Lio/vertx/core/Promise<Ljava/lang/Integer;>;
private void lambda$9(io.vertx.core.Promise);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
invokeinterface org.infinispan.AdvancedCache.keySet:()Lorg/infinispan/CacheSet;
invokeinterface org.infinispan.CacheSet.stream:()Lorg/infinispan/CacheStream;
invokedynamic get()Lorg/infinispan/util/function/SerializableSupplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$10()Ljava/util/stream/Collector; (6)
()Ljava/util/stream/Collector;
1
invokestatic org.infinispan.stream.CacheCollectors.serializableCollector:(Lorg/infinispan/util/function/SerializableSupplier;)Ljava/util/stream/Collector;
invokeinterface org.infinispan.CacheStream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Set
astore 2
start local 2 1: aload 1
aload 2
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
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/ext/cluster/infinispan/impl/DataConverter.fromCachedObject(Ljava/lang/Object;)Ljava/lang/Object; (6)
(Ljava/lang/Object;)Ljava/lang/Object;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
invokestatic java.util.stream.Collectors.toSet:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Set
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 2 2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 3 1 future Lio/vertx/core/Promise<Ljava/util/Set<TK;>;>;
1 2 2 cacheKeys Ljava/util/Set<Ljava/lang/Object;>;
private void lambda$12(io.vertx.core.Promise);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
invokeinterface org.infinispan.AdvancedCache.values:()Lorg/infinispan/CacheCollection;
invokeinterface org.infinispan.CacheCollection.stream:()Lorg/infinispan/CacheStream;
invokedynamic get()Lorg/infinispan/util/function/SerializableSupplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$13()Ljava/util/stream/Collector; (6)
()Ljava/util/stream/Collector;
1
invokestatic org.infinispan.stream.CacheCollectors.serializableCollector:(Lorg/infinispan/util/function/SerializableSupplier;)Ljava/util/stream/Collector;
invokeinterface org.infinispan.CacheStream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
astore 2
start local 2 1: aload 1
aload 2
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
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/ext/cluster/infinispan/impl/DataConverter.fromCachedObject(Ljava/lang/Object;)Ljava/lang/Object; (6)
(Ljava/lang/Object;)Ljava/lang/Object;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
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
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 2 2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 3 1 future Lio/vertx/core/Promise<Ljava/util/List<TV;>;>;
1 2 2 cacheValues Ljava/util/List<Ljava/lang/Object;>;
private void lambda$15(io.vertx.core.Promise);
descriptor: (Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=8, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl.cache:Lorg/infinispan/AdvancedCache;
invokeinterface org.infinispan.AdvancedCache.entrySet:()Lorg/infinispan/CacheSet;
invokeinterface org.infinispan.CacheSet.stream:()Lorg/infinispan/CacheStream;
1: invokedynamic get()Lorg/infinispan/util/function/SerializableSupplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$16()Ljava/util/stream/Collector; (6)
()Ljava/util/stream/Collector;
1
invokestatic org.infinispan.stream.CacheCollectors.serializableCollector:(Lorg/infinispan/util/function/SerializableSupplier;)Ljava/util/stream/Collector;
invokeinterface org.infinispan.CacheStream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Map
2: astore 2
start local 2 3: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 3
start local 3 4: aload 2
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 9
StackMap locals: io.vertx.ext.cluster.infinispan.impl.InfinispanAsyncMapImpl io.vertx.core.Promise java.util.Map java.util.Map top java.util.Iterator
StackMap stack:
5: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 4
start local 4 6: aload 4
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.fromCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 6
start local 6 7: aload 4
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.fromCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 7
start local 7 8: aload 3
aload 6
aload 7
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 7 end local 6 end local 4 9: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
10: aload 1
aload 3
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 3 end local 2 11: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl<TK;TV;>;
0 12 1 future Lio/vertx/core/Promise<Ljava/util/Map<TK;TV;>;>;
3 11 2 cacheEntries Ljava/util/Map<Ljava/lang/Object;Ljava/lang/Object;>;
4 11 3 result Ljava/util/Map<TK;TV;>;
6 9 4 entry Ljava/util/Map$Entry<Ljava/lang/Object;Ljava/lang/Object;>;
7 9 6 k TK;
8 9 7 v TV;
private static java.util.Map$Entry lambda$24(java.util.Map$Entry);
descriptor: (Ljava/util/Map$Entry;)Ljava/util/Map$Entry;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=1
start local 0 0: aload 0
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.fromCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 1
start local 1 1: aload 0
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.fromCachedObject:(Ljava/lang/Object;)Ljava/lang/Object;
astore 2
start local 2 2: new java.util.AbstractMap$SimpleImmutableEntry
dup
aload 1
aload 2
invokespecial java.util.AbstractMap$SimpleImmutableEntry.<init>:(Ljava/lang/Object;Ljava/lang/Object;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 cacheEntry Ljava/util/Map$Entry<Ljava/lang/Object;Ljava/lang/Object;>;
1 3 1 key TK;
2 3 2 value TV;
private static void lambda$1(io.vertx.core.Promise, java.lang.Throwable, java.lang.Void);
descriptor: (Lio/vertx/core/Promise;Ljava/lang/Throwable;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: aload 0
aload 1
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 h Ljava/lang/Void;
private static void lambda$2(io.vertx.core.Promise, java.lang.Object, java.lang.Void);
descriptor: (Lio/vertx/core/Promise;Ljava/lang/Object;Ljava/lang/Void;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=3, args_size=3
start local 2 0: aload 0
aload 1
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 h Ljava/lang/Void;
private static java.util.stream.Collector lambda$10();
descriptor: ()Ljava/util/stream/Collector;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=0, args_size=0
0: invokestatic java.util.stream.Collectors.toSet:()Ljava/util/stream/Collector;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.util.stream.Collector lambda$13();
descriptor: ()Ljava/util/stream/Collector;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=0, args_size=0
0: invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.util.stream.Collector lambda$16();
descriptor: ()Ljava/util/stream/Collector;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=0, args_size=0
0: 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;
java/util/Map$Entry.getKey()Ljava/lang/Object; (9 itf)
(Ljava/util/Map$Entry;)Ljava/lang/Object;
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;
java/util/Map$Entry.getValue()Ljava/lang/Object; (9 itf)
(Ljava/util/Map$Entry;)Ljava/lang/Object;
invokestatic java.util.stream.Collectors.toMap:(Ljava/util/function/Function;Ljava/util/function/Function;)Ljava/util/stream/Collector;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.lang.Object $deserializeLambda$(java.lang.invoke.SerializedLambda);
descriptor: (Ljava/lang/invoke/SerializedLambda;)Ljava/lang/Object;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=1
0: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodName:()Ljava/lang/String;
astore 1
iconst_m1
istore 2
aload 1
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 3
471912476: 1
471912479: 2
471912482: 3
default: 4
}
StackMap locals: java.lang.String int
StackMap stack:
1: aload 1
ldc "lambda$10"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 4
iconst_0
istore 2
goto 4
StackMap locals:
StackMap stack:
2: aload 1
ldc "lambda$13"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 4
iconst_1
istore 2
goto 4
StackMap locals:
StackMap stack:
3: aload 1
ldc "lambda$16"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 4
iconst_2
istore 2
StackMap locals:
StackMap stack:
4: iload 2
lookupswitch { // 3
0: 5
1: 6
2: 7
default: 8
}
StackMap locals:
StackMap stack:
5: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
bipush 6
if_icmpne 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
ldc "org/infinispan/util/function/SerializableSupplier"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
ldc "get"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
ldc "()Ljava/lang/Object;"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
ldc "io/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
ldc "()Ljava/util/stream/Collector;"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
invokedynamic get()Lorg/infinispan/util/function/SerializableSupplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$10()Ljava/util/stream/Collector; (6)
()Ljava/util/stream/Collector;
1
areturn
StackMap locals:
StackMap stack:
6: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
bipush 6
if_icmpne 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
ldc "org/infinispan/util/function/SerializableSupplier"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
ldc "get"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
ldc "()Ljava/lang/Object;"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
ldc "io/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
ldc "()Ljava/util/stream/Collector;"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
invokedynamic get()Lorg/infinispan/util/function/SerializableSupplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$13()Ljava/util/stream/Collector; (6)
()Ljava/util/stream/Collector;
1
areturn
StackMap locals:
StackMap stack:
7: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
bipush 6
if_icmpne 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
ldc "org/infinispan/util/function/SerializableSupplier"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
ldc "get"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
ldc "()Ljava/lang/Object;"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
ldc "io/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
ldc "()Ljava/util/stream/Collector;"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 8
invokedynamic get()Lorg/infinispan/util/function/SerializableSupplier;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.altMetafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;
Method arguments:
()Ljava/lang/Object;
io/vertx/ext/cluster/infinispan/impl/InfinispanAsyncMapImpl.lambda$16()Ljava/util/stream/Collector; (6)
()Ljava/util/stream/Collector;
1
areturn
StackMap locals:
StackMap stack:
8: new java.lang.IllegalArgumentException
dup
ldc "Invalid lambda deserialization"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
LocalVariableTable:
Start End Slot Name Signature
}
Signature: <K:Ljava/lang/Object;V:Ljava/lang/Object;>Ljava/lang/Object;Lio/vertx/core/shareddata/AsyncMap<TK;TV;>;Lio/vertx/ext/cluster/infinispan/InfinispanAsyncMap<TK;TV;>;
SourceFile: "InfinispanAsyncMapImpl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public SimpleImmutableEntry = java.util.AbstractMap$SimpleImmutableEntry of java.util.AbstractMap
public abstract Entry = java.util.Map$Entry of java.util.Map