http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-infinispan: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse) 
public class io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper
  super_class: java.lang.Object
{
  private static final io.vertx.core.impl.logging.Logger log;
    descriptor: Lio/vertx/core/impl/logging/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final org.infinispan.multimap.impl.EmbeddedMultimapCache<java.lang.String, org.infinispan.commons.marshall.WrappedBytes> subsCache;
    descriptor: Lorg/infinispan/multimap/impl/EmbeddedMultimapCache;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lorg/infinispan/multimap/impl/EmbeddedMultimapCache<Ljava/lang/String;Lorg/infinispan/commons/marshall/WrappedBytes;>;

  private final io.vertx.core.spi.cluster.NodeSelector nodeSelector;
    descriptor: Lio/vertx/core/spi/cluster/NodeSelector;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper$EntryListener entryListener;
    descriptor: Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper$EntryListener;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 60
            ldc Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper;
            invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
            putstatic io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.log:Lio/vertx/core/impl/logging/Logger;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(org.infinispan.manager.DefaultCacheManager, io.vertx.core.spi.cluster.NodeSelector);
    descriptor: (Lorg/infinispan/manager/DefaultCacheManager;Lio/vertx/core/spi/cluster/NodeSelector;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=5, args_size=3
        start local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
        start local 1 // org.infinispan.manager.DefaultCacheManager cacheManager
        start local 2 // io.vertx.core.spi.cluster.NodeSelector nodeSelector
         0: .line 66
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 68
            aload 1 /* cacheManager */
            invokestatic org.infinispan.multimap.api.embedded.EmbeddedMultimapCacheManagerFactory.from:(Lorg/infinispan/manager/EmbeddedCacheManager;)Lorg/infinispan/multimap/api/embedded/MultimapCacheManager;
            astore 3 /* multimapCacheManager */
        start local 3 // org.infinispan.multimap.api.embedded.MultimapCacheManager multimapCacheManager
         2: .line 69
            aload 0 /* this */
            aload 3 /* multimapCacheManager */
            ldc "__vertx.subs"
            invokeinterface org.infinispan.multimap.api.embedded.MultimapCacheManager.get:(Ljava/lang/String;)Lorg/infinispan/multimap/api/embedded/MultimapCache;
            checkcast org.infinispan.multimap.impl.EmbeddedMultimapCache
            putfield io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.subsCache:Lorg/infinispan/multimap/impl/EmbeddedMultimapCache;
         3: .line 70
            aload 0 /* this */
            aload 2 /* nodeSelector */
            putfield io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.nodeSelector:Lio/vertx/core/spi/cluster/NodeSelector;
         4: .line 71
            aload 0 /* this */
            new io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper$EntryListener
            dup
            aload 0 /* this */
            invokespecial io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper$EntryListener.<init>:(Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper;)V
            putfield io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.entryListener:Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper$EntryListener;
         5: .line 72
            invokestatic java.util.stream.Stream.builder:()Ljava/util/stream/Stream$Builder;
         6: .line 73
            ldc Lorg/infinispan/notifications/cachelistener/annotation/CacheEntryCreated;
            invokeinterface java.util.stream.Stream$Builder.add:(Ljava/lang/Object;)Ljava/util/stream/Stream$Builder;
         7: .line 74
            ldc Lorg/infinispan/notifications/cachelistener/annotation/CacheEntryModified;
            invokeinterface java.util.stream.Stream$Builder.add:(Ljava/lang/Object;)Ljava/util/stream/Stream$Builder;
         8: .line 75
            ldc Lorg/infinispan/notifications/cachelistener/annotation/CacheEntryRemoved;
            invokeinterface java.util.stream.Stream$Builder.add:(Ljava/lang/Object;)Ljava/util/stream/Stream$Builder;
         9: .line 76
            invokeinterface java.util.stream.Stream$Builder.build:()Ljava/util/stream/Stream;
        10: .line 77
            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
        11: .line 72
            astore 4 /* filterAnnotations */
        start local 4 // java.util.Set filterAnnotations
        12: .line 78
            aload 0 /* this */
            getfield io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.subsCache:Lorg/infinispan/multimap/impl/EmbeddedMultimapCache;
            invokevirtual org.infinispan.multimap.impl.EmbeddedMultimapCache.getCache:()Lorg/infinispan/Cache;
        13: .line 79
            aload 0 /* this */
            getfield io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.entryListener:Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper$EntryListener;
            new io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper$EventFilter
            dup
            invokespecial io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper$EventFilter.<init>:()V
            new io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper$EventConverter
            dup
            invokespecial io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper$EventConverter.<init>:()V
            aload 4 /* filterAnnotations */
            invokeinterface org.infinispan.Cache.addFilteredListener:(Ljava/lang/Object;Lorg/infinispan/notifications/cachelistener/filter/CacheEventFilter;Lorg/infinispan/notifications/cachelistener/filter/CacheEventConverter;Ljava/util/Set;)V
        14: .line 80
            return
        end local 4 // java.util.Set filterAnnotations
        end local 3 // org.infinispan.multimap.api.embedded.MultimapCacheManager multimapCacheManager
        end local 2 // io.vertx.core.spi.cluster.NodeSelector nodeSelector
        end local 1 // org.infinispan.manager.DefaultCacheManager cacheManager
        end local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
      LocalVariableTable:
        Start  End  Slot                  Name  Signature
            0   15     0                  this  Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper;
            0   15     1          cacheManager  Lorg/infinispan/manager/DefaultCacheManager;
            0   15     2          nodeSelector  Lio/vertx/core/spi/cluster/NodeSelector;
            2   15     3  multimapCacheManager  Lorg/infinispan/multimap/api/embedded/MultimapCacheManager<Ljava/lang/String;Lorg/infinispan/commons/marshall/WrappedBytes;>;
           12   15     4     filterAnnotations  Ljava/util/Set<Ljava/lang/Class<+Ljava/lang/annotation/Annotation;>;>;
    MethodParameters:
              Name  Flags
      cacheManager  
      nodeSelector  

  public java.util.concurrent.CompletableFuture<java.util.List<io.vertx.core.spi.cluster.RegistrationInfo>> get(java.lang.String);
    descriptor: (Ljava/lang/String;)Ljava/util/concurrent/CompletableFuture;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
        start local 1 // java.lang.String address
         0: .line 83
            aload 0 /* this */
            getfield io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.subsCache:Lorg/infinispan/multimap/impl/EmbeddedMultimapCache;
            aload 1 /* address */
            invokevirtual org.infinispan.multimap.impl.EmbeddedMultimapCache.get:(Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
         1: .line 84
            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/SubsCacheHelper.lambda$0(Ljava/util/Collection;)Ljava/util/List; (6)
                  (Ljava/util/Collection;)Ljava/util/List;
            invokevirtual java.util.concurrent.CompletableFuture.thenApply:(Ljava/util/function/Function;)Ljava/util/concurrent/CompletableFuture;
         2: .line 83
            areturn
        end local 1 // java.lang.String address
        end local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper;
            0    3     1  address  Ljava/lang/String;
    Signature: (Ljava/lang/String;)Ljava/util/concurrent/CompletableFuture<Ljava/util/List<Lio/vertx/core/spi/cluster/RegistrationInfo;>;>;
    MethodParameters:
         Name  Flags
      address  

  public java.util.concurrent.CompletableFuture<java.lang.Void> put(java.lang.String, io.vertx.core.spi.cluster.RegistrationInfo);
    descriptor: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)Ljava/util/concurrent/CompletableFuture;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=3
        start local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
        start local 1 // java.lang.String address
        start local 2 // io.vertx.core.spi.cluster.RegistrationInfo registrationInfo
         0: .line 93
            aload 2 /* registrationInfo */
            invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)[B
            astore 3 /* bytes */
        start local 3 // byte[] bytes
         1: .line 94
            aload 0 /* this */
            getfield io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.subsCache:Lorg/infinispan/multimap/impl/EmbeddedMultimapCache;
            aload 1 /* address */
            new org.infinispan.commons.marshall.WrappedByteArray
            dup
            aload 3 /* bytes */
            invokespecial org.infinispan.commons.marshall.WrappedByteArray.<init>:([B)V
            invokevirtual org.infinispan.multimap.impl.EmbeddedMultimapCache.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
            areturn
        end local 3 // byte[] bytes
        end local 2 // io.vertx.core.spi.cluster.RegistrationInfo registrationInfo
        end local 1 // java.lang.String address
        end local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    2     0              this  Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper;
            0    2     1           address  Ljava/lang/String;
            0    2     2  registrationInfo  Lio/vertx/core/spi/cluster/RegistrationInfo;
            1    2     3             bytes  [B
    Signature: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)Ljava/util/concurrent/CompletableFuture<Ljava/lang/Void;>;
    MethodParameters:
                  Name  Flags
      address           
      registrationInfo  

  public java.util.concurrent.CompletableFuture<java.lang.Void> remove(java.lang.String, io.vertx.core.spi.cluster.RegistrationInfo);
    descriptor: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)Ljava/util/concurrent/CompletableFuture;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=3
        start local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
        start local 1 // java.lang.String address
        start local 2 // io.vertx.core.spi.cluster.RegistrationInfo registrationInfo
         0: .line 98
            aload 2 /* registrationInfo */
            invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.toCachedObject:(Ljava/lang/Object;)[B
            astore 3 /* bytes */
        start local 3 // byte[] bytes
         1: .line 99
            aload 0 /* this */
            getfield io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.subsCache:Lorg/infinispan/multimap/impl/EmbeddedMultimapCache;
            aload 1 /* address */
            new org.infinispan.commons.marshall.WrappedByteArray
            dup
            aload 3 /* bytes */
            invokespecial org.infinispan.commons.marshall.WrappedByteArray.<init>:([B)V
            invokevirtual org.infinispan.multimap.impl.EmbeddedMultimapCache.remove:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/concurrent/CompletableFuture;
         2: .line 100
            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/SubsCacheHelper.lambda$3(Ljava/lang/Boolean;)Ljava/lang/Void; (6)
                  (Ljava/lang/Boolean;)Ljava/lang/Void;
            invokevirtual java.util.concurrent.CompletableFuture.thenApply:(Ljava/util/function/Function;)Ljava/util/concurrent/CompletableFuture;
         3: .line 99
            areturn
        end local 3 // byte[] bytes
        end local 2 // io.vertx.core.spi.cluster.RegistrationInfo registrationInfo
        end local 1 // java.lang.String address
        end local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    4     0              this  Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper;
            0    4     1           address  Ljava/lang/String;
            0    4     2  registrationInfo  Lio/vertx/core/spi/cluster/RegistrationInfo;
            1    4     3             bytes  [B
    Signature: (Ljava/lang/String;Lio/vertx/core/spi/cluster/RegistrationInfo;)Ljava/util/concurrent/CompletableFuture<Ljava/lang/Void;>;
    MethodParameters:
                  Name  Flags
      address           
      registrationInfo  

  public void removeAllForNode(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
        start local 1 // java.lang.String nodeId
         0: .line 104
            aload 0 /* this */
            getfield io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.subsCache:Lorg/infinispan/multimap/impl/EmbeddedMultimapCache;
            aload 1 /* nodeId */
            invokedynamic test(Ljava/lang/String;)Lorg/infinispan/util/function/SerializablePredicate;
              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/ext/cluster/infinispan/impl/SubsCacheHelper.lambda$4(Ljava/lang/String;Lorg/infinispan/commons/marshall/WrappedBytes;)Z (6)
                  (Lorg/infinispan/commons/marshall/WrappedBytes;)Z
                  1
            invokevirtual org.infinispan.multimap.impl.EmbeddedMultimapCache.remove:(Lorg/infinispan/util/function/SerializablePredicate;)Ljava/util/concurrent/CompletableFuture;
            pop
         1: .line 108
            return
        end local 1 // java.lang.String nodeId
        end local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper;
            0    2     1  nodeId  Ljava/lang/String;
    MethodParameters:
        Name  Flags
      nodeId  

  public void close();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
         0: .line 111
            aload 0 /* this */
            getfield io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.subsCache:Lorg/infinispan/multimap/impl/EmbeddedMultimapCache;
            invokevirtual org.infinispan.multimap.impl.EmbeddedMultimapCache.getCache:()Lorg/infinispan/Cache;
            aload 0 /* this */
            getfield io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.entryListener:Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper$EntryListener;
            invokeinterface org.infinispan.Cache.removeListener:(Ljava/lang/Object;)V
         1: .line 112
            return
        end local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper;

  private void fireRegistrationUpdateEvent(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
        start local 1 // java.lang.String address
         0: .line 115
            aload 0 /* this */
            aload 1 /* address */
            invokevirtual io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.get:(Ljava/lang/String;)Ljava/util/concurrent/CompletableFuture;
            aload 0 /* this */
            aload 1 /* address */
            invokedynamic accept(Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper;Ljava/lang/String;)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/SubsCacheHelper.lambda$5(Ljava/lang/String;Ljava/util/List;Ljava/lang/Throwable;)V (7)
                  (Ljava/util/List;Ljava/lang/Throwable;)V
            invokevirtual java.util.concurrent.CompletableFuture.whenComplete:(Ljava/util/function/BiConsumer;)Ljava/util/concurrent/CompletableFuture;
            pop
         1: .line 123
            return
        end local 1 // java.lang.String address
        end local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper;
            0    2     1  address  Ljava/lang/String;
    MethodParameters:
         Name  Flags
      address  

  private static java.util.List lambda$0(java.util.Collection);
    descriptor: (Ljava/util/Collection;)Ljava/util/List;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.util.Collection collection
         0: .line 85
            aload 0 /* collection */
            invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
         1: .line 86
            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;
                  org/infinispan/commons/marshall/WrappedBytes.getBytes()[B (9 itf)
                  (Lorg/infinispan/commons/marshall/WrappedBytes;)[B
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
         2: .line 87
            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([B)Ljava/lang/Object; (6)
                  ([B)Lio/vertx/core/spi/cluster/RegistrationInfo;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
         3: .line 88
            invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
            invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
            checkcast java.util.List
         4: .line 85
            areturn
        end local 0 // java.util.Collection collection
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    5     0  collection  Ljava/util/Collection<Lorg/infinispan/commons/marshall/WrappedBytes;>;

  private static java.lang.Void lambda$3(java.lang.Boolean);
    descriptor: (Ljava/lang/Boolean;)Ljava/lang/Void;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // java.lang.Boolean v
         0: .line 100
            aconst_null
            areturn
        end local 0 // java.lang.Boolean v
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     v  Ljava/lang/Boolean;

  private static boolean lambda$4(java.lang.String, org.infinispan.commons.marshall.WrappedBytes);
    descriptor: (Ljava/lang/String;Lorg/infinispan/commons/marshall/WrappedBytes;)Z
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=2
        start local 1 // org.infinispan.commons.marshall.WrappedBytes value
         0: .line 105
            aload 1 /* value */
            invokeinterface org.infinispan.commons.marshall.WrappedBytes.getBytes:()[B
            invokestatic io.vertx.ext.cluster.infinispan.impl.DataConverter.fromCachedObject:([B)Ljava/lang/Object;
            checkcast io.vertx.core.spi.cluster.RegistrationInfo
            astore 2 /* registrationInfo */
        start local 2 // io.vertx.core.spi.cluster.RegistrationInfo registrationInfo
         1: .line 106
            aload 0
            aload 2 /* registrationInfo */
            invokevirtual io.vertx.core.spi.cluster.RegistrationInfo.nodeId:()Ljava/lang/String;
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ireturn
        end local 2 // io.vertx.core.spi.cluster.RegistrationInfo registrationInfo
        end local 1 // org.infinispan.commons.marshall.WrappedBytes value
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    2     1             value  Lorg/infinispan/commons/marshall/WrappedBytes;
            1    2     2  registrationInfo  Lio/vertx/core/spi/cluster/RegistrationInfo;

  private void lambda$5(java.lang.String, java.util.List, java.lang.Throwable);
    descriptor: (Ljava/lang/String;Ljava/util/List;Ljava/lang/Throwable;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=5, locals=4, args_size=4
        start local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
        start local 2 // java.util.List registrationInfos
        start local 3 // java.lang.Throwable throwable
         0: .line 116
            aload 3 /* throwable */
            ifnonnull 3
         1: .line 117
            aload 0 /* this */
            getfield io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.nodeSelector:Lio/vertx/core/spi/cluster/NodeSelector;
            new io.vertx.core.spi.cluster.RegistrationUpdateEvent
            dup
            aload 1
            aload 2 /* registrationInfos */
            invokespecial io.vertx.core.spi.cluster.RegistrationUpdateEvent.<init>:(Ljava/lang/String;Ljava/util/List;)V
            invokeinterface io.vertx.core.spi.cluster.NodeSelector.registrationsUpdated:(Lio/vertx/core/spi/cluster/RegistrationUpdateEvent;)V
         2: .line 118
            goto 5
         3: .line 119
      StackMap locals:
      StackMap stack:
            getstatic io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.log:Lio/vertx/core/impl/logging/Logger;
            ldc "A failure occured while retrieving the updated registrations"
            aload 3 /* throwable */
            invokeinterface io.vertx.core.impl.logging.Logger.trace:(Ljava/lang/Object;Ljava/lang/Throwable;)V
         4: .line 120
            aload 0 /* this */
            getfield io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper.nodeSelector:Lio/vertx/core/spi/cluster/NodeSelector;
            new io.vertx.core.spi.cluster.RegistrationUpdateEvent
            dup
            aload 1
            invokestatic java.util.Collections.emptyList:()Ljava/util/List;
            invokespecial io.vertx.core.spi.cluster.RegistrationUpdateEvent.<init>:(Ljava/lang/String;Ljava/util/List;)V
            invokeinterface io.vertx.core.spi.cluster.NodeSelector.registrationsUpdated:(Lio/vertx/core/spi/cluster/RegistrationUpdateEvent;)V
         5: .line 122
      StackMap locals:
      StackMap stack:
            return
        end local 3 // java.lang.Throwable throwable
        end local 2 // java.util.List registrationInfos
        end local 0 // io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    6     0               this  Lio/vertx/ext/cluster/infinispan/impl/SubsCacheHelper;
            0    6     2  registrationInfos  Ljava/util/List<Lio/vertx/core/spi/cluster/RegistrationInfo;>;
            0    6     3          throwable  Ljava/lang/Throwable;

  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=4, locals=3, args_size=1
         0: .line 1
            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 { // 1
          -1647345001: 1
              default: 2
          }
      StackMap locals: java.lang.String int
      StackMap stack:
         1: aload 1
            ldc "lambda$4"
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifeq 2
            iconst_0
            istore 2
      StackMap locals:
      StackMap stack:
         2: iload 2
            lookupswitch { // 1
                    0: 3
              default: 4
          }
      StackMap locals:
      StackMap stack:
         3: aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getImplMethodKind:()I
            bipush 6
            if_icmpne 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceClass:()Ljava/lang/String;
            ldc "org/infinispan/util/function/SerializablePredicate"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getFunctionalInterfaceMethodName:()Ljava/lang/String;
            ldc "test"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            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 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getImplClass:()Ljava/lang/String;
            ldc "io/vertx/ext/cluster/infinispan/impl/SubsCacheHelper"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            aload 0
            invokevirtual java.lang.invoke.SerializedLambda.getImplMethodSignature:()Ljava/lang/String;
            ldc "(Ljava/lang/String;Lorg/infinispan/commons/marshall/WrappedBytes;)Z"
            invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 4
            aload 0
            iconst_0
            invokevirtual java.lang.invoke.SerializedLambda.getCapturedArg:(I)Ljava/lang/Object;
            checkcast java.lang.String
            invokedynamic test(Ljava/lang/String;)Lorg/infinispan/util/function/SerializablePredicate;
              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/ext/cluster/infinispan/impl/SubsCacheHelper.lambda$4(Ljava/lang/String;Lorg/infinispan/commons/marshall/WrappedBytes;)Z (6)
                  (Lorg/infinispan/commons/marshall/WrappedBytes;)Z
                  1
            areturn
      StackMap locals:
      StackMap stack:
         4: 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
}
SourceFile: "SubsCacheHelper.java"
NestMembers:
  io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper$EntryListener  io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper$EventConverter  io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper$EventFilter
InnerClasses:
  private EntryListener = io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper$EntryListener of io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper
  private EventConverter = io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper$EventConverter of io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper
  private EventFilter = io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper$EventFilter of io.vertx.ext.cluster.infinispan.impl.SubsCacheHelper
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  public abstract Builder = java.util.stream.Stream$Builder of java.util.stream.Stream