public class io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl<K, V> implements io.vertx.core.spi.cluster.AsyncMultiMap<K, V>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl
super_class: java.lang.Object
{
private final org.apache.ignite.IgniteCache<K, java.util.Set<V>> cache;
descriptor: Lorg/apache/ignite/IgniteCache;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Lorg/apache/ignite/IgniteCache<TK;Ljava/util/Set<TV;>;>;
private final io.vertx.core.impl.VertxInternal vertx;
descriptor: Lio/vertx/core/impl/VertxInternal;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final io.vertx.core.impl.TaskQueue taskQueue;
descriptor: Lio/vertx/core/impl/TaskQueue;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.ConcurrentMap<K, io.vertx.spi.cluster.ignite.impl.ChoosableIterableImpl<V>> subs;
descriptor: Ljava/util/concurrent/ConcurrentMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/ConcurrentMap<TK;Lio/vertx/spi/cluster/ignite/impl/ChoosableIterableImpl<TV;>;>;
public void <init>(org.apache.ignite.IgniteCache<K, java.util.Set<V>>, io.vertx.core.Vertx);
descriptor: (Lorg/apache/ignite/IgniteCache;Lio/vertx/core/Vertx;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, 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
new io.vertx.core.impl.TaskQueue
dup
invokespecial io.vertx.core.impl.TaskQueue.<init>:()V
putfield io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.taskQueue:Lio/vertx/core/impl/TaskQueue;
2: aload 0
new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
putfield io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.subs:Ljava/util/concurrent/ConcurrentMap;
3: aload 1
ldc Lorg/apache/ignite/Ignite;
invokeinterface org.apache.ignite.IgniteCache.unwrap:(Ljava/lang/Class;)Ljava/lang/Object;
checkcast org.apache.ignite.Ignite
invokeinterface org.apache.ignite.Ignite.events:()Lorg/apache/ignite/IgniteEvents;
aload 0
aload 1
invokedynamic apply(Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl;Lorg/apache/ignite/IgniteCache;)Lorg/apache/ignite/lang/IgnitePredicate;
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;)Z
io/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$0(Lorg/apache/ignite/IgniteCache;Lorg/apache/ignite/events/Event;)Z (7)
(Lorg/apache/ignite/events/Event;)Z
1
iconst_1
newarray 10
dup
iconst_0
4: bipush 65
iastore
5: invokeinterface org.apache.ignite.IgniteEvents.localListen:(Lorg/apache/ignite/lang/IgnitePredicate;[I)V
6: aload 0
aload 1
putfield io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.cache:Lorg/apache/ignite/IgniteCache;
7: aload 0
aload 2
checkcast io.vertx.core.impl.VertxInternal
putfield io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
8: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl<TK;TV;>;
0 9 1 cache Lorg/apache/ignite/IgniteCache<TK;Ljava/util/Set<TV;>;>;
0 9 2 vertx Lio/vertx/core/Vertx;
Signature: (Lorg/apache/ignite/IgniteCache<TK;Ljava/util/Set<TV;>;>;Lio/vertx/core/Vertx;)V
MethodParameters:
Name Flags
cache
vertx
public void add(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=3, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 2
invokestatic io.vertx.spi.cluster.ignite.impl.ClusterSerializationUtils.marshal:(Ljava/lang/Object;)Ljava/lang/Object;
astore 4
start local 4 1: aload 0
aload 4
aload 1
invokedynamic apply(Ljava/lang/Object;Ljava/lang/Object;)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/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$1(Ljava/lang/Object;Ljava/lang/Object;Lorg/apache/ignite/IgniteCache;)Lorg/apache/ignite/lang/IgniteFuture; (6)
(Lorg/apache/ignite/IgniteCache;)Lorg/apache/ignite/lang/IgniteFuture;
2: aload 3
3: invokevirtual io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.execute:(Ljava/util/function/Function;Lio/vertx/core/Handler;)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/spi/cluster/ignite/impl/AsyncMultiMapImpl<TK;TV;>;
0 5 1 key TK;
0 5 2 value TV;
0 5 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
1 5 4 val0 TV;
Signature: (TK;TV;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
key
value
handler
public void get(K, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.spi.cluster.ChoosableIterable<V>>>);
descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
1: aload 1
invokedynamic apply(Ljava/lang/Object;)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/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$3(Ljava/lang/Object;Lorg/apache/ignite/IgniteCache;)Lorg/apache/ignite/lang/IgniteFuture; (6)
(Lorg/apache/ignite/IgniteCache;)Lorg/apache/ignite/lang/IgniteFuture;
2: aload 0
aload 1
invokedynamic apply(Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl;Ljava/lang/Object;)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/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$4(Ljava/lang/Object;Ljava/util/Set;)Lio/vertx/core/spi/cluster/ChoosableIterable; (7)
(Ljava/util/Set;)Lio/vertx/core/spi/cluster/ChoosableIterable;
3: aload 2
4: invokevirtual io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.execute:(Ljava/util/function/Function;Ljava/util/function/Function;Lio/vertx/core/Handler;)V
5: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl<TK;TV;>;
0 6 1 key TK;
0 6 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/spi/cluster/ChoosableIterable<TV;>;>;>;
Signature: (TK;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/core/spi/cluster/ChoosableIterable<TV;>;>;>;)V
MethodParameters:
Name Flags
key
handler
public void remove(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=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
aload 2
aload 1
invokedynamic apply(Ljava/lang/Object;Ljava/lang/Object;)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/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$7(Ljava/lang/Object;Ljava/lang/Object;Lorg/apache/ignite/IgniteCache;)Lorg/apache/ignite/lang/IgniteFuture; (6)
(Lorg/apache/ignite/IgniteCache;)Lorg/apache/ignite/lang/IgniteFuture;
1: aload 3
2: invokevirtual io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.execute:(Ljava/util/function/Function;Lio/vertx/core/Handler;)V
3: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl<TK;TV;>;
0 4 1 key TK;
0 4 2 value TV;
0 4 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Boolean;>;>;
Signature: (TK;TV;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Boolean;>;>;)V
MethodParameters:
Name Flags
key
value
handler
public void removeAllForValue(V, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/lang/Object;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokedynamic test(Ljava/lang/Object;)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/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$11(Ljava/lang/Object;Ljava/lang/Object;)Z (6)
(Ljava/lang/Object;)Z
aload 2
invokevirtual io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.removeAllMatching:(Ljava/util/function/Predicate;Lio/vertx/core/Handler;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl<TK;TV;>;
0 2 1 value TV;
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (TV;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
value
handler
public void removeAllMatching(java.util.function.Predicate<V>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Ljava/util/function/Predicate;Lio/vertx/core/Handler;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
aload 0
aload 1
invokedynamic handle(Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl;Ljava/util/function/Predicate;)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/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$12(Ljava/util/function/Predicate;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: aload 0
getfield io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.taskQueue:Lio/vertx/core/impl/TaskQueue;
aload 2
2: invokeinterface io.vertx.core.impl.ContextInternal.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/impl/TaskQueue;Lio/vertx/core/Handler;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl<TK;TV;>;
0 4 1 p Ljava/util/function/Predicate<TV;>;
0 4 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
Signature: (Ljava/util/function/Predicate<TV;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
MethodParameters:
Name Flags
p
handler
private <T> void execute(java.util.function.Function<org.apache.ignite.IgniteCache<K, java.util.Set<V>>, org.apache.ignite.lang.IgniteFuture<T>>, io.vertx.core.Handler<io.vertx.core.AsyncResult<T>>);
descriptor: (Ljava/util/function/Function;Lio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokestatic java.util.function.UnaryOperator.identity:()Ljava/util/function/UnaryOperator;
aload 2
invokevirtual io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.execute:(Ljava/util/function/Function;Ljava/util/function/Function;Lio/vertx/core/Handler;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl<TK;TV;>;
0 2 1 cacheOp Ljava/util/function/Function<Lorg/apache/ignite/IgniteCache<TK;Ljava/util/Set<TV;>;>;Lorg/apache/ignite/lang/IgniteFuture<TT;>;>;
0 2 2 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;
Signature: <T:Ljava/lang/Object;>(Ljava/util/function/Function<Lorg/apache/ignite/IgniteCache<TK;Ljava/util/Set<TV;>;>;Lorg/apache/ignite/lang/IgniteFuture<TT;>;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TT;>;>;)V
MethodParameters:
Name Flags
cacheOp
handler
private <T, R> void execute(java.util.function.Function<org.apache.ignite.IgniteCache<K, java.util.Set<V>>, org.apache.ignite.lang.IgniteFuture<T>>, java.util.function.Function<T, R>, io.vertx.core.Handler<io.vertx.core.AsyncResult<R>>);
descriptor: (Ljava/util/function/Function;Ljava/util/function/Function;Lio/vertx/core/Handler;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
getfield io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.vertx:Lio/vertx/core/impl/VertxInternal;
invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
aload 0
aload 1
aload 2
invokedynamic handle(Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl;Ljava/util/function/Function;Ljava/util/function/Function;)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/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$14(Ljava/util/function/Function;Ljava/util/function/Function;Lio/vertx/core/Promise;)V (7)
(Lio/vertx/core/Promise;)V
1: aload 0
getfield io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.taskQueue:Lio/vertx/core/impl/TaskQueue;
aload 3
2: invokeinterface io.vertx.core.impl.ContextInternal.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/impl/TaskQueue;Lio/vertx/core/Handler;)V
3: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl<TK;TV;>;
0 4 1 cacheOp Ljava/util/function/Function<Lorg/apache/ignite/IgniteCache<TK;Ljava/util/Set<TV;>;>;Lorg/apache/ignite/lang/IgniteFuture<TT;>;>;
0 4 2 mapper Ljava/util/function/Function<TT;TR;>;
0 4 3 handler Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TR;>;>;
Signature: <T:Ljava/lang/Object;R:Ljava/lang/Object;>(Ljava/util/function/Function<Lorg/apache/ignite/IgniteCache<TK;Ljava/util/Set<TV;>;>;Lorg/apache/ignite/lang/IgniteFuture<TT;>;>;Ljava/util/function/Function<TT;TR;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TR;>;>;)V
MethodParameters:
Name Flags
cacheOp
mapper
handler
private boolean lambda$0(org.apache.ignite.IgniteCache, org.apache.ignite.events.Event);
descriptor: (Lorg/apache/ignite/IgniteCache;Lorg/apache/ignite/events/Event;)Z
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=5, locals=5, args_size=3
start local 0 start local 2 0: aload 2
instanceof org.apache.ignite.events.CacheEvent
ifne 2
1: new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "Unknown event received: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
aload 2
checkcast org.apache.ignite.events.CacheEvent
astore 3
start local 3 3: aload 3
invokevirtual org.apache.ignite.events.CacheEvent.cacheName:()Ljava/lang/String;
aload 1
invokeinterface org.apache.ignite.IgniteCache.getName:()Ljava/lang/String;
invokestatic java.util.Objects.equals:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 10
4: aload 1
checkcast org.apache.ignite.internal.processors.cache.IgniteCacheProxy
invokeinterface org.apache.ignite.internal.processors.cache.IgniteCacheProxy.context:()Lorg/apache/ignite/internal/processors/cache/GridCacheContext;
invokevirtual org.apache.ignite.internal.processors.cache.GridCacheContext.localNodeId:()Ljava/util/UUID;
aload 3
invokevirtual org.apache.ignite.events.CacheEvent.eventNode:()Lorg/apache/ignite/cluster/ClusterNode;
invokeinterface org.apache.ignite.cluster.ClusterNode.id:()Ljava/util/UUID;
invokevirtual java.util.UUID.equals:(Ljava/lang/Object;)Z
ifeq 10
5: aload 3
invokevirtual org.apache.ignite.events.CacheEvent.key:()Ljava/lang/Object;
invokestatic io.vertx.spi.cluster.ignite.impl.ClusterSerializationUtils.unmarshal:(Ljava/lang/Object;)Ljava/lang/Object;
astore 4
start local 4 6: aload 3
invokevirtual org.apache.ignite.events.CacheEvent.type:()I
tableswitch { // 65 - 65
65: 7
default: 9
}
7: StackMap locals: org.apache.ignite.events.CacheEvent java.lang.Object
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.subs:Ljava/util/concurrent/ConcurrentMap;
aload 4
invokeinterface java.util.concurrent.ConcurrentMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
8: goto 10
9: StackMap locals:
StackMap stack:
new java.lang.IllegalArgumentException
dup
new java.lang.StringBuilder
dup
ldc "Unknown event received: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
end local 4 10: StackMap locals:
StackMap stack:
iconst_1
ireturn
end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl<TK;TV;>;
0 11 2 event Lorg/apache/ignite/events/Event;
3 11 3 cacheEvent Lorg/apache/ignite/events/CacheEvent;
6 10 4 key TK;
private static org.apache.ignite.lang.IgniteFuture lambda$1(java.lang.Object, java.lang.Object, org.apache.ignite.IgniteCache);
descriptor: (Ljava/lang/Object;Ljava/lang/Object;Lorg/apache/ignite/IgniteCache;)Lorg/apache/ignite/lang/IgniteFuture;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=3
start local 2 0: aload 2
aload 1
invokestatic io.vertx.spi.cluster.ignite.impl.ClusterSerializationUtils.marshal:(Ljava/lang/Object;)Ljava/lang/Object;
aload 0
invokedynamic process(Ljava/lang/Object;)Lorg/apache/ignite/cache/CacheEntryProcessor;
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:
(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$2(Ljava/lang/Object;Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Void; (6)
(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Void;
1
iconst_0
anewarray java.lang.Object
invokeinterface org.apache.ignite.IgniteCache.invokeAsync:(Ljava/lang/Object;Lorg/apache/ignite/cache/CacheEntryProcessor;[Ljava/lang/Object;)Lorg/apache/ignite/lang/IgniteFuture;
1: areturn
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 2 2 cache Lorg/apache/ignite/IgniteCache<TK;Ljava/util/Set<TV;>;>;
private static org.apache.ignite.lang.IgniteFuture lambda$3(java.lang.Object, org.apache.ignite.IgniteCache);
descriptor: (Ljava/lang/Object;Lorg/apache/ignite/IgniteCache;)Lorg/apache/ignite/lang/IgniteFuture;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokestatic io.vertx.spi.cluster.ignite.impl.ClusterSerializationUtils.marshal:(Ljava/lang/Object;)Ljava/lang/Object;
invokeinterface org.apache.ignite.IgniteCache.getAsync:(Ljava/lang/Object;)Lorg/apache/ignite/lang/IgniteFuture;
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 cache Lorg/apache/ignite/IgniteCache<TK;Ljava/util/Set<TV;>;>;
private io.vertx.core.spi.cluster.ChoosableIterable lambda$4(java.lang.Object, java.util.Set);
descriptor: (Ljava/lang/Object;Ljava/util/Set;)Lio/vertx/core/spi/cluster/ChoosableIterable;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=6, args_size=3
start local 0 start local 2 0: aconst_null
astore 3
start local 3 1: aload 2
ifnull 3
2: 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/spi/cluster/ignite/impl/ClusterSerializationUtils.unmarshal(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
astore 3
3: StackMap locals: java.util.Set
StackMap stack:
aload 3
astore 4
start local 4 4: aload 0
getfield io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.subs:Ljava/util/concurrent/ConcurrentMap;
aload 1
aload 4
invokedynamic apply(Ljava/util/Set;)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/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$6(Ljava/util/Set;Ljava/lang/Object;Lio/vertx/spi/cluster/ignite/impl/ChoosableIterableImpl;)Lio/vertx/spi/cluster/ignite/impl/ChoosableIterableImpl; (6)
(Ljava/lang/Object;Lio/vertx/spi/cluster/ignite/impl/ChoosableIterableImpl;)Lio/vertx/spi/cluster/ignite/impl/ChoosableIterableImpl;
invokeinterface java.util.concurrent.ConcurrentMap.compute:(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object;
checkcast io.vertx.spi.cluster.ignite.impl.ChoosableIterableImpl
astore 5
start local 5 5: aload 5
ifnonnull 6
invokestatic io.vertx.spi.cluster.ignite.impl.ChoosableIterableImpl.empty:()Lio/vertx/core/spi/cluster/ChoosableIterable;
goto 7
StackMap locals: java.util.Set io.vertx.spi.cluster.ignite.impl.ChoosableIterableImpl
StackMap stack:
6: aload 5
StackMap locals:
StackMap stack: io.vertx.core.spi.cluster.ChoosableIterable
7: areturn
end local 5 end local 4 end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl<TK;TV;>;
0 8 2 items Ljava/util/Set<TV;>;
1 8 3 unmarshalledItems Ljava/util/Set<TV;>;
4 8 4 items0 Ljava/util/Set<TV;>;
5 8 5 it Lio/vertx/spi/cluster/ignite/impl/ChoosableIterableImpl<TV;>;
private static org.apache.ignite.lang.IgniteFuture lambda$7(java.lang.Object, java.lang.Object, org.apache.ignite.IgniteCache);
descriptor: (Ljava/lang/Object;Ljava/lang/Object;Lorg/apache/ignite/IgniteCache;)Lorg/apache/ignite/lang/IgniteFuture;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=3
start local 2 0: aload 2
aload 1
invokestatic io.vertx.spi.cluster.ignite.impl.ClusterSerializationUtils.marshal:(Ljava/lang/Object;)Ljava/lang/Object;
aload 0
invokedynamic process(Ljava/lang/Object;)Lorg/apache/ignite/cache/CacheEntryProcessor;
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:
(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$8(Ljava/lang/Object;Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Boolean; (6)
(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Boolean;
1
iconst_0
anewarray java.lang.Object
invokeinterface org.apache.ignite.IgniteCache.invokeAsync:(Ljava/lang/Object;Lorg/apache/ignite/cache/CacheEntryProcessor;[Ljava/lang/Object;)Lorg/apache/ignite/lang/IgniteFuture;
1: areturn
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 2 2 cache Lorg/apache/ignite/IgniteCache<TK;Ljava/util/Set<TV;>;>;
private static boolean lambda$11(java.lang.Object, java.lang.Object);
descriptor: (Ljava/lang/Object;Ljava/lang/Object;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokestatic io.vertx.spi.cluster.ignite.impl.ClusterSerializationUtils.unmarshal:(Ljava/lang/Object;)Ljava/lang/Object;
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 obj TV;
private void lambda$12(java.util.function.Predicate, io.vertx.core.Promise);
descriptor: (Ljava/util/function/Predicate;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=8, args_size=3
start local 0 start local 2 0: iconst_0
istore 3
start local 3 1: aconst_null
astore 4
start local 4 2: iconst_0
istore 5
start local 5 3: goto 14
4: StackMap locals: int java.lang.Exception int
StackMap stack:
aload 0
getfield io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.cache:Lorg/apache/ignite/IgniteCache;
invokeinterface org.apache.ignite.IgniteCache.iterator:()Ljava/util/Iterator;
astore 7
goto 7
StackMap locals: io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl java.util.function.Predicate io.vertx.core.Promise int java.lang.Exception int top java.util.Iterator
StackMap stack:
5: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast javax.cache.Cache$Entry
astore 6
start local 6 6: aload 0
getfield io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.cache:Lorg/apache/ignite/IgniteCache;
aload 6
invokeinterface javax.cache.Cache$Entry.getKey:()Ljava/lang/Object;
aload 1
invokedynamic process(Ljava/util/function/Predicate;)Lorg/apache/ignite/cache/CacheEntryProcessor;
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:
(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$13(Ljava/util/function/Predicate;Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object; (6)
(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object;
1
iconst_0
anewarray java.lang.Object
invokeinterface org.apache.ignite.IgniteCache.invokeAsync:(Ljava/lang/Object;Lorg/apache/ignite/cache/CacheEntryProcessor;[Ljava/lang/Object;)Lorg/apache/ignite/lang/IgniteFuture;
pop
end local 6 7: StackMap locals:
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
8: iconst_1
istore 3
9: aload 2
invokeinterface io.vertx.core.Promise.complete:()V
10: goto 15
11: StackMap locals: io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl java.util.function.Predicate io.vertx.core.Promise int java.lang.Exception int
StackMap stack: javax.cache.CacheException
astore 6
start local 6 12: aload 6
astore 4
end local 6 13: iinc 5 1
StackMap locals:
StackMap stack:
14: iload 5
iconst_5
if_icmplt 4
end local 5 15: StackMap locals:
StackMap stack:
iload 3
ifne 17
16: aload 2
aload 4
invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
end local 4 end local 3 17: StackMap locals:
StackMap stack:
return
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl<TK;TV;>;
0 18 2 fut Lio/vertx/core/Promise<Ljava/lang/Void;>;
1 17 3 success Z
2 17 4 err Ljava/lang/Exception;
3 15 5 i I
6 7 6 entry Ljavax/cache/Cache$Entry<TK;Ljava/util/Set<TV;>;>;
12 13 6 e Ljavax/cache/CacheException;
Exception table:
from to target type
4 10 11 Class javax.cache.CacheException
private void lambda$14(java.util.function.Function, java.util.function.Function, io.vertx.core.Promise);
descriptor: (Ljava/util/function/Function;Ljava/util/function/Function;Lio/vertx/core/Promise;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=5, args_size=4
start local 0 start local 3 0: aload 1
aload 0
getfield io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl.cache:Lorg/apache/ignite/IgniteCache;
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.ignite.lang.IgniteFuture
astore 4
start local 4 1: aload 3
aload 2
aload 4
invokeinterface org.apache.ignite.lang.IgniteFuture.get:()Ljava/lang/Object;
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
end local 4 2: return
end local 3 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl<TK;TV;>;
0 3 3 f Lio/vertx/core/Promise<TR;>;
1 2 4 future Lorg/apache/ignite/lang/IgniteFuture<TT;>;
private static java.lang.Void lambda$2(java.lang.Object, javax.cache.processor.MutableEntry, java.lang.Object[]);
descriptor: (Ljava/lang/Object;Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Void;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=4, args_size=3
start local 1 start local 2 0: aload 1
invokeinterface javax.cache.processor.MutableEntry.getValue:()Ljava/lang/Object;
checkcast java.util.Set
astore 3
start local 3 1: aload 3
ifnonnull 3
2: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 3
3: StackMap locals: java.util.Set
StackMap stack:
aload 3
aload 0
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
4: aload 1
aload 3
invokeinterface javax.cache.processor.MutableEntry.setValue:(Ljava/lang/Object;)V
5: aconst_null
areturn
end local 3 end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 6 1 entry Ljavax/cache/processor/MutableEntry<TK;Ljava/util/Set<TV;>;>;
0 6 2 arguments [Ljava/lang/Object;
1 6 3 values Ljava/util/Set<TV;>;
Exceptions:
throws javax.cache.processor.EntryProcessorException
private static io.vertx.spi.cluster.ignite.impl.ChoosableIterableImpl lambda$6(java.util.Set, java.lang.Object, io.vertx.spi.cluster.ignite.impl.ChoosableIterableImpl);
descriptor: (Ljava/util/Set;Ljava/lang/Object;Lio/vertx/spi/cluster/ignite/impl/ChoosableIterableImpl;)Lio/vertx/spi/cluster/ignite/impl/ChoosableIterableImpl;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=3, args_size=3
start local 1 start local 2 0: aload 0
ifnull 1
aload 0
invokeinterface java.util.Set.isEmpty:()Z
ifeq 2
1: StackMap locals:
StackMap stack:
aconst_null
areturn
2: StackMap locals:
StackMap stack:
aload 2
ifnonnull 4
3: new io.vertx.spi.cluster.ignite.impl.ChoosableIterableImpl
dup
new java.util.ArrayList
dup
aload 0
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
invokespecial io.vertx.spi.cluster.ignite.impl.ChoosableIterableImpl.<init>:(Ljava/util/List;)V
areturn
4: StackMap locals:
StackMap stack:
aload 2
new java.util.ArrayList
dup
aload 0
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
invokevirtual io.vertx.spi.cluster.ignite.impl.ChoosableIterableImpl.update:(Ljava/util/List;)V
5: aload 2
areturn
end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 6 1 k TK;
0 6 2 oldValue Lio/vertx/spi/cluster/ignite/impl/ChoosableIterableImpl<TV;>;
private static java.lang.Boolean lambda$8(java.lang.Object, javax.cache.processor.MutableEntry, java.lang.Object[]);
descriptor: (Ljava/lang/Object;Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Boolean;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=5, args_size=3
start local 1 start local 2 0: aload 1
invokeinterface javax.cache.processor.MutableEntry.getValue:()Ljava/lang/Object;
checkcast java.util.Set
astore 3
start local 3 1: aload 3
ifnull 10
2: aload 3
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/spi/cluster/ignite/impl/ClusterSerializationUtils.unmarshal(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
astore 3
3: aload 3
aload 0
invokeinterface java.util.Set.remove:(Ljava/lang/Object;)Z
istore 4
start local 4 4: aload 3
invokeinterface java.util.Set.isEmpty:()Z
ifeq 7
5: aload 1
invokeinterface javax.cache.processor.MutableEntry.remove:()V
6: goto 9
7: StackMap locals: java.util.Set int
StackMap stack:
aload 3
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/spi/cluster/ignite/impl/ClusterSerializationUtils.marshal(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
astore 3
8: aload 1
aload 3
invokeinterface javax.cache.processor.MutableEntry.setValue:(Ljava/lang/Object;)V
9: StackMap locals:
StackMap stack:
iload 4
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
areturn
end local 4 10: StackMap locals:
StackMap stack:
iconst_0
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
areturn
end local 3 end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 11 1 entry Ljavax/cache/processor/MutableEntry<TK;Ljava/util/Set<TV;>;>;
0 11 2 arguments [Ljava/lang/Object;
1 11 3 values Ljava/util/Set<TV;>;
4 10 4 removed Z
Exceptions:
throws javax.cache.processor.EntryProcessorException
private static java.lang.Object lambda$13(java.util.function.Predicate, javax.cache.processor.MutableEntry, java.lang.Object[]);
descriptor: (Ljava/util/function/Predicate;Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=4, args_size=3
start local 1 start local 2 0: aload 1
invokeinterface javax.cache.processor.MutableEntry.getValue:()Ljava/lang/Object;
checkcast java.util.Set
astore 3
start local 3 1: aload 3
ifnull 7
2: aload 3
aload 0
invokeinterface java.util.Set.removeIf:(Ljava/util/function/Predicate;)Z
pop
3: aload 3
invokeinterface java.util.Set.isEmpty:()Z
ifeq 6
4: aload 1
invokeinterface javax.cache.processor.MutableEntry.remove:()V
5: goto 7
6: StackMap locals: java.util.Set
StackMap stack:
aload 1
aload 3
invokeinterface javax.cache.processor.MutableEntry.setValue:(Ljava/lang/Object;)V
7: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 3 end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 8 1 e Ljavax/cache/processor/MutableEntry<TK;Ljava/util/Set<TV;>;>;
0 8 2 args [Ljava/lang/Object;
1 8 3 values Ljava/util/Set<TV;>;
Exceptions:
throws javax.cache.processor.EntryProcessorException
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=8, 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 { // 4
-1647345005: 1
-1647345003: 2
-1647344997: 3
471912479: 4
default: 5
}
StackMap locals: java.lang.String int
StackMap stack:
1: aload 1
ldc "lambda$0"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 5
iconst_0
istore 2
goto 5
StackMap locals:
StackMap stack:
2: aload 1
ldc "lambda$2"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 5
iconst_1
istore 2
goto 5
StackMap locals:
StackMap stack:
3: aload 1
ldc "lambda$8"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 5
iconst_2
istore 2
goto 5
StackMap locals:
StackMap stack:
4: aload 1
ldc "lambda$13"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 5
iconst_3
istore 2
StackMap locals:
StackMap stack:
5: iload 2
lookupswitch { // 4
0: 6
1: 7
2: 8
3: 9
default: 10
}
StackMap locals:
StackMap stack:
6: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
bipush 7
if_icmpne 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
ldc "org/apache/ignite/lang/IgnitePredicate"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
ldc "apply"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
ldc "(Ljava/lang/Object;)Z"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
ldc "io/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
ldc "(Lorg/apache/ignite/IgniteCache;Lorg/apache/ignite/events/Event;)Z"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
iconst_0
invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
checkcast io.vertx.spi.cluster.ignite.impl.AsyncMultiMapImpl
aload 0
iconst_1
invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
checkcast org.apache.ignite.IgniteCache
invokedynamic apply(Lio/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl;Lorg/apache/ignite/IgniteCache;)Lorg/apache/ignite/lang/IgnitePredicate;
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;)Z
io/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$0(Lorg/apache/ignite/IgniteCache;Lorg/apache/ignite/events/Event;)Z (7)
(Lorg/apache/ignite/events/Event;)Z
1
areturn
StackMap locals:
StackMap stack:
7: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
bipush 6
if_icmpne 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
ldc "org/apache/ignite/cache/CacheEntryProcessor"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
ldc "process"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
ldc "(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object;"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
ldc "io/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
ldc "(Ljava/lang/Object;Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Void;"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
iconst_0
invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
checkcast java.lang.Object
invokedynamic process(Ljava/lang/Object;)Lorg/apache/ignite/cache/CacheEntryProcessor;
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:
(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$2(Ljava/lang/Object;Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Void; (6)
(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Void;
1
areturn
StackMap locals:
StackMap stack:
8: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
bipush 6
if_icmpne 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
ldc "org/apache/ignite/cache/CacheEntryProcessor"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
ldc "process"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
ldc "(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object;"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
ldc "io/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
ldc "(Ljava/lang/Object;Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Boolean;"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
iconst_0
invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
checkcast java.lang.Object
invokedynamic process(Ljava/lang/Object;)Lorg/apache/ignite/cache/CacheEntryProcessor;
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:
(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$8(Ljava/lang/Object;Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Boolean; (6)
(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Boolean;
1
areturn
StackMap locals:
StackMap stack:
9: aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
bipush 6
if_icmpne 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
ldc "org/apache/ignite/cache/CacheEntryProcessor"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
ldc "process"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodSignature:()Ljava/lang/String;
ldc "(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object;"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
ldc "io/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
ldc "(Ljava/util/function/Predicate;Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object;"
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 10
aload 0
iconst_0
invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
checkcast java.util.function.Predicate
invokedynamic process(Ljava/util/function/Predicate;)Lorg/apache/ignite/cache/CacheEntryProcessor;
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:
(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/spi/cluster/ignite/impl/AsyncMultiMapImpl.lambda$13(Ljava/util/function/Predicate;Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object; (6)
(Ljavax/cache/processor/MutableEntry;[Ljava/lang/Object;)Ljava/lang/Object;
1
areturn
StackMap locals:
StackMap stack:
10: 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/spi/cluster/AsyncMultiMap<TK;TV;>;
SourceFile: "AsyncMultiMapImpl.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Entry = javax.cache.Cache$Entry of javax.cache.Cache