http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-service-discovery-parent/vertx-service-discovery-bridge-consul: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse) 
public class io.vertx.servicediscovery.consul.ConsulServiceImporter implements io.vertx.servicediscovery.spi.ServiceImporter
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.servicediscovery.consul.ConsulServiceImporter
  super_class: java.lang.Object
{
  private io.vertx.servicediscovery.spi.ServicePublisher publisher;
    descriptor: Lio/vertx/servicediscovery/spi/ServicePublisher;
    flags: (0x0002) ACC_PRIVATE

  private io.vertx.ext.consul.ConsulClient client;
    descriptor: Lio/vertx/ext/consul/ConsulClient;
    flags: (0x0002) ACC_PRIVATE

  private static final io.vertx.core.impl.logging.Logger LOGGER;
    descriptor: Lio/vertx/core/impl/logging/Logger;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final java.util.List<io.vertx.servicediscovery.consul.ImportedConsulService> imports;
    descriptor: Ljava/util/List;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;

  private long scanTask;
    descriptor: J
    flags: (0x0002) ACC_PRIVATE

  private io.vertx.core.Vertx vertx;
    descriptor: Lio/vertx/core/Vertx;
    flags: (0x0002) ACC_PRIVATE

  private java.lang.String upThreshold;
    descriptor: Ljava/lang/String;
    flags: (0x0002) ACC_PRIVATE

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

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
         0: .line 45
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 52
            aload 0 /* this */
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            putfield io.vertx.servicediscovery.consul.ConsulServiceImporter.imports:Ljava/util/List;
         2: .line 53
            aload 0 /* this */
            ldc -1
            putfield io.vertx.servicediscovery.consul.ConsulServiceImporter.scanTask:J
         3: .line 45
            return
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;

  public void start(io.vertx.core.Vertx, io.vertx.servicediscovery.spi.ServicePublisher, io.vertx.core.json.JsonObject, io.vertx.core.Promise<java.lang.Void>);
    descriptor: (Lio/vertx/core/Vertx;Lio/vertx/servicediscovery/spi/ServicePublisher;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Promise;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=7, args_size=5
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 1 // io.vertx.core.Vertx vertx
        start local 2 // io.vertx.servicediscovery.spi.ServicePublisher publisher
        start local 3 // io.vertx.core.json.JsonObject configuration
        start local 4 // io.vertx.core.Promise completion
         0: .line 59
            aload 0 /* this */
            aload 1 /* vertx */
            putfield io.vertx.servicediscovery.consul.ConsulServiceImporter.vertx:Lio/vertx/core/Vertx;
         1: .line 60
            aload 0 /* this */
            aload 2 /* publisher */
            putfield io.vertx.servicediscovery.consul.ConsulServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
         2: .line 61
            aload 0 /* this */
            aload 3 /* configuration */
            ldc "up_threshold"
            ldc "passing"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
            putfield io.vertx.servicediscovery.consul.ConsulServiceImporter.upThreshold:Ljava/lang/String;
         3: .line 63
            new io.vertx.ext.consul.ConsulClientOptions
            dup
            invokespecial io.vertx.ext.consul.ConsulClientOptions.<init>:()V
         4: .line 64
            aload 3 /* configuration */
            ldc "host"
            ldc "localhost"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
            invokevirtual io.vertx.ext.consul.ConsulClientOptions.setHost:(Ljava/lang/String;)Lio/vertx/ext/consul/ConsulClientOptions;
         5: .line 65
            aload 3 /* configuration */
            ldc "port"
            sipush 8500
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokevirtual io.vertx.core.json.JsonObject.getInteger:(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer;
            invokevirtual java.lang.Integer.intValue:()I
            invokevirtual io.vertx.ext.consul.ConsulClientOptions.setPort:(I)Lio/vertx/ext/consul/ConsulClientOptions;
         6: .line 66
            aload 3 /* configuration */
            ldc "dc"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
            invokevirtual io.vertx.ext.consul.ConsulClientOptions.setDc:(Ljava/lang/String;)Lio/vertx/ext/consul/ConsulClientOptions;
         7: .line 67
            aload 3 /* configuration */
            ldc "acl_token"
            invokevirtual io.vertx.core.json.JsonObject.getString:(Ljava/lang/String;)Ljava/lang/String;
            invokevirtual io.vertx.ext.consul.ConsulClientOptions.setAclToken:(Ljava/lang/String;)Lio/vertx/ext/consul/ConsulClientOptions;
         8: .line 63
            astore 5 /* opts */
        start local 5 // io.vertx.ext.consul.ConsulClientOptions opts
         9: .line 69
            aload 0 /* this */
            aload 1 /* vertx */
            aload 5 /* opts */
            invokestatic io.vertx.ext.consul.ConsulClient.create:(Lio/vertx/core/Vertx;Lio/vertx/ext/consul/ConsulClientOptions;)Lio/vertx/ext/consul/ConsulClient;
            putfield io.vertx.servicediscovery.consul.ConsulServiceImporter.client:Lio/vertx/ext/consul/ConsulClient;
        10: .line 71
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 6 /* imports */
        start local 6 // io.vertx.core.Promise imports
        11: .line 73
            aload 0 /* this */
            aload 6 /* imports */
            invokevirtual io.vertx.servicediscovery.consul.ConsulServiceImporter.retrieveServicesFromConsul:(Lio/vertx/core/Promise;)V
        12: .line 75
            aload 6 /* imports */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            aload 0 /* this */
            aload 3 /* configuration */
            aload 1 /* vertx */
            aload 4 /* completion */
            invokedynamic handle(Lio/vertx/servicediscovery/consul/ConsulServiceImporter;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Vertx;Lio/vertx/core/Promise;)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/servicediscovery/consul/ConsulServiceImporter.lambda$0(Lio/vertx/core/json/JsonObject;Lio/vertx/core/Vertx;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
        13: .line 95
            return
        end local 6 // io.vertx.core.Promise imports
        end local 5 // io.vertx.ext.consul.ConsulClientOptions opts
        end local 4 // io.vertx.core.Promise completion
        end local 3 // io.vertx.core.json.JsonObject configuration
        end local 2 // io.vertx.servicediscovery.spi.ServicePublisher publisher
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   14     0           this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0   14     1          vertx  Lio/vertx/core/Vertx;
            0   14     2      publisher  Lio/vertx/servicediscovery/spi/ServicePublisher;
            0   14     3  configuration  Lio/vertx/core/json/JsonObject;
            0   14     4     completion  Lio/vertx/core/Promise<Ljava/lang/Void;>;
            9   14     5           opts  Lio/vertx/ext/consul/ConsulClientOptions;
           11   14     6        imports  Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;>;
    Signature: (Lio/vertx/core/Vertx;Lio/vertx/servicediscovery/spi/ServicePublisher;Lio/vertx/core/json/JsonObject;Lio/vertx/core/Promise<Ljava/lang/Void;>;)V
    MethodParameters:
               Name  Flags
      vertx          
      publisher      
      configuration  
      completion     

  private io.vertx.core.Handler<java.lang.Throwable> getErrorHandler(io.vertx.core.Promise);
    descriptor: (Lio/vertx/core/Promise;)Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=2, args_size=2
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 1 // io.vertx.core.Promise future
         0: .line 99
            aload 1 /* future */
            invokedynamic handle(Lio/vertx/core/Promise;)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/servicediscovery/consul/ConsulServiceImporter.lambda$3(Lio/vertx/core/Promise;Ljava/lang/Throwable;)V (6)
                  (Ljava/lang/Throwable;)V
            areturn
        end local 1 // io.vertx.core.Promise future
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0    this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    1     1  future  Lio/vertx/core/Promise;
    Signature: (Lio/vertx/core/Promise;)Lio/vertx/core/Handler<Ljava/lang/Throwable;>;
    MethodParameters:
        Name  Flags
      future  

  private void retrieveServicesFromConsul(io.vertx.core.Promise<java.util.List<io.vertx.servicediscovery.consul.ImportedConsulService>>);
    descriptor: (Lio/vertx/core/Promise;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 1 // io.vertx.core.Promise completed
         0: .line 109
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.client:Lio/vertx/ext/consul/ConsulClient;
            aload 0 /* this */
            aload 1 /* completed */
            invokedynamic handle(Lio/vertx/servicediscovery/consul/ConsulServiceImporter;Lio/vertx/core/Promise;)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/servicediscovery/consul/ConsulServiceImporter.lambda$4(Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.ext.consul.ConsulClient.catalogServices:(Lio/vertx/core/Handler;)Lio/vertx/ext/consul/ConsulClient;
            pop
         1: .line 116
            return
        end local 1 // io.vertx.core.Promise completed
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    2     1  completed  Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;>;
    Signature: (Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;>;)V
    MethodParameters:
           Name  Flags
      completed  

  private boolean isCheckOK(io.vertx.ext.consul.CheckStatus);
    descriptor: (Lio/vertx/ext/consul/CheckStatus;)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 1 // io.vertx.ext.consul.CheckStatus checkStatus
         0: .line 119
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.upThreshold:Ljava/lang/String;
            ldc "passing"
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifeq 2
         1: .line 120
            aload 1 /* checkStatus */
            getstatic io.vertx.ext.consul.CheckStatus.PASSING:Lio/vertx/ext/consul/CheckStatus;
            invokevirtual io.vertx.ext.consul.CheckStatus.equals:(Ljava/lang/Object;)Z
            ireturn
         2: .line 122
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.upThreshold:Ljava/lang/String;
            ldc "warning"
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifeq 5
         3: .line 123
            aload 1 /* checkStatus */
            getstatic io.vertx.ext.consul.CheckStatus.WARNING:Lio/vertx/ext/consul/CheckStatus;
            invokevirtual io.vertx.ext.consul.CheckStatus.equals:(Ljava/lang/Object;)Z
            ifne 4
            aload 1 /* checkStatus */
            getstatic io.vertx.ext.consul.CheckStatus.PASSING:Lio/vertx/ext/consul/CheckStatus;
            invokevirtual io.vertx.ext.consul.CheckStatus.equals:(Ljava/lang/Object;)Z
            ifne 4
            iconst_0
            ireturn
      StackMap locals:
      StackMap stack:
         4: iconst_1
            ireturn
         5: .line 125
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 1 // io.vertx.ext.consul.CheckStatus checkStatus
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    6     0         this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    6     1  checkStatus  Lio/vertx/ext/consul/CheckStatus;
    MethodParameters:
             Name  Flags
      checkStatus  

  private void retrieveIndividualServices(io.vertx.ext.consul.ServiceList, io.vertx.core.Promise<java.util.List<io.vertx.servicediscovery.consul.ImportedConsulService>>);
    descriptor: (Lio/vertx/ext/consul/ServiceList;Lio/vertx/core/Promise;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 1 // io.vertx.ext.consul.ServiceList list
        start local 2 // io.vertx.core.Promise completed
         0: .line 129
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 3 /* futures */
        start local 3 // java.util.List futures
         1: .line 130
            aload 1 /* list */
            invokevirtual io.vertx.ext.consul.ServiceList.getList:()Ljava/util/List;
            aload 0 /* this */
            aload 2 /* completed */
            aload 3 /* futures */
            invokedynamic accept(Lio/vertx/servicediscovery/consul/ConsulServiceImporter;Lio/vertx/core/Promise;Ljava/util/List;)Ljava/util/function/Consumer;
              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/servicediscovery/consul/ConsulServiceImporter.lambda$5(Lio/vertx/core/Promise;Ljava/util/List;Lio/vertx/ext/consul/Service;)V (7)
                  (Lio/vertx/ext/consul/Service;)V
            invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
         2: .line 144
            aload 3 /* futures */
            invokestatic io.vertx.core.CompositeFuture.all:(Ljava/util/List;)Lio/vertx/core/CompositeFuture;
            aload 0 /* this */
            aload 3 /* futures */
            aload 2 /* completed */
            invokedynamic handle(Lio/vertx/servicediscovery/consul/ConsulServiceImporter;Ljava/util/List;Lio/vertx/core/Promise;)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/servicediscovery/consul/ConsulServiceImporter.lambda$7(Ljava/util/List;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.CompositeFuture.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/CompositeFuture;
            pop
         3: .line 189
            return
        end local 3 // java.util.List futures
        end local 2 // io.vertx.core.Promise completed
        end local 1 // io.vertx.ext.consul.ServiceList list
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    4     0       this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    4     1       list  Lio/vertx/ext/consul/ServiceList;
            0    4     2  completed  Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;>;
            1    4     3    futures  Ljava/util/List<Lio/vertx/core/Future;>;
    Signature: (Lio/vertx/ext/consul/ServiceList;Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;>;)V
    MethodParameters:
           Name  Flags
      list       
      completed  

  private void importService(java.util.List<io.vertx.ext.consul.ServiceEntry>, io.vertx.core.Promise<java.util.List<io.vertx.servicediscovery.consul.ImportedConsulService>>);
    descriptor: (Ljava/util/List;Lio/vertx/core/Promise;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=15, args_size=3
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 1 // java.util.List list
        start local 2 // io.vertx.core.Promise future
         0: .line 192
            aload 1 /* list */
            invokeinterface java.util.List.isEmpty:()Z
            ifeq 3
         1: .line 193
            aload 2 /* future */
            ldc "no service with the given name"
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/String;)V
         2: .line 194
            goto 32
         3: .line 195
      StackMap locals:
      StackMap stack:
            aload 1 /* list */
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
         4: .line 196
            aload 0 /* this */
            invokedynamic test(Lio/vertx/servicediscovery/consul/ConsulServiceImporter;)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/servicediscovery/consul/ConsulServiceImporter.lambda$14(Lio/vertx/ext/consul/ServiceEntry;)Z (7)
                  (Lio/vertx/ext/consul/ServiceEntry;)Z
            invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
         5: .line 199
            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
         6: .line 195
            astore 3 /* serviceEntries */
        start local 3 // java.util.List serviceEntries
         7: .line 201
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 4 /* importedServices */
        start local 4 // java.util.List importedServices
         8: .line 203
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 5 /* registrations */
        start local 5 // java.util.List registrations
         9: .line 204
            iconst_0
            istore 6 /* i */
        start local 6 // int i
        10: goto 30
        11: .line 205
      StackMap locals: io.vertx.servicediscovery.consul.ConsulServiceImporter java.util.List io.vertx.core.Promise java.util.List java.util.List java.util.List int
      StackMap stack:
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 7 /* registration */
        start local 7 // io.vertx.core.Promise registration
        12: .line 207
            aload 3 /* serviceEntries */
            iload 6 /* i */
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            checkcast io.vertx.ext.consul.ServiceEntry
            astore 8 /* consulService */
        start local 8 // io.vertx.ext.consul.ServiceEntry consulService
        13: .line 208
            aload 8 /* consulService */
            invokevirtual io.vertx.ext.consul.ServiceEntry.getService:()Lio/vertx/ext/consul/Service;
            invokevirtual io.vertx.ext.consul.Service.getId:()Ljava/lang/String;
            astore 9 /* id */
        start local 9 // java.lang.String id
        14: .line 209
            aload 8 /* consulService */
            invokevirtual io.vertx.ext.consul.ServiceEntry.getService:()Lio/vertx/ext/consul/Service;
            invokevirtual io.vertx.ext.consul.Service.getName:()Ljava/lang/String;
            astore 10 /* name */
        start local 10 // java.lang.String name
        15: .line 210
            aload 0 /* this */
            aload 8 /* consulService */
            invokevirtual io.vertx.ext.consul.ServiceEntry.getService:()Lio/vertx/ext/consul/Service;
            invokevirtual io.vertx.servicediscovery.consul.ConsulServiceImporter.createRecord:(Lio/vertx/ext/consul/Service;)Lio/vertx/servicediscovery/Record;
            astore 11 /* record */
        start local 11 // io.vertx.servicediscovery.Record record
        16: .line 213
            aload 0 /* this */
            aload 9 /* id */
            invokevirtual io.vertx.servicediscovery.consul.ConsulServiceImporter.getImportedServiceById:(Ljava/lang/String;)Lio/vertx/servicediscovery/consul/ImportedConsulService;
            astore 12 /* imported */
        start local 12 // io.vertx.servicediscovery.consul.ImportedConsulService imported
        17: .line 214
            aload 12 /* imported */
            ifnull 21
        18: .line 215
            aload 4 /* importedServices */
            aload 12 /* imported */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        19: .line 216
            aload 7 /* registration */
            invokeinterface io.vertx.core.Promise.complete:()V
        20: .line 217
            goto 28
        21: .line 218
      StackMap locals: io.vertx.servicediscovery.consul.ConsulServiceImporter java.util.List io.vertx.core.Promise java.util.List java.util.List java.util.List int io.vertx.core.Promise io.vertx.ext.consul.ServiceEntry java.lang.String java.lang.String io.vertx.servicediscovery.Record io.vertx.servicediscovery.consul.ImportedConsulService
      StackMap stack:
            getstatic io.vertx.servicediscovery.consul.ConsulServiceImporter.LOGGER:Lio/vertx/core/impl/logging/Logger;
            new java.lang.StringBuilder
            dup
            ldc "Importing service "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 11 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getName:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc " ("
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 9 /* id */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ")"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
        22: .line 219
            ldc " from consul"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
        23: .line 218
            invokeinterface io.vertx.core.impl.logging.Logger.info:(Ljava/lang/Object;)V
        24: .line 220
            new io.vertx.servicediscovery.consul.ImportedConsulService
            dup
            aload 10 /* name */
            aload 9 /* id */
            aload 11 /* record */
            invokespecial io.vertx.servicediscovery.consul.ImportedConsulService.<init>:(Ljava/lang/String;Ljava/lang/String;Lio/vertx/servicediscovery/Record;)V
            astore 13 /* service */
        start local 13 // io.vertx.servicediscovery.consul.ImportedConsulService service
        25: .line 221
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 14 /* promise */
        start local 14 // io.vertx.core.Promise promise
        26: .line 222
            aload 14 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            aload 4 /* importedServices */
            aload 7 /* registration */
            invokedynamic handle(Ljava/util/List;Lio/vertx/core/Promise;)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/servicediscovery/consul/ConsulServiceImporter.lambda$16(Ljava/util/List;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
        27: .line 230
            aload 13 /* service */
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
            aload 14 /* promise */
            invokevirtual io.vertx.servicediscovery.consul.ImportedConsulService.register:(Lio/vertx/servicediscovery/spi/ServicePublisher;Lio/vertx/core/Promise;)Lio/vertx/servicediscovery/consul/ImportedConsulService;
            pop
        end local 14 // io.vertx.core.Promise promise
        end local 13 // io.vertx.servicediscovery.consul.ImportedConsulService service
        28: .line 232
      StackMap locals:
      StackMap stack:
            aload 5 /* registrations */
            aload 7 /* registration */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 12 // io.vertx.servicediscovery.consul.ImportedConsulService imported
        end local 11 // io.vertx.servicediscovery.Record record
        end local 10 // java.lang.String name
        end local 9 // java.lang.String id
        end local 8 // io.vertx.ext.consul.ServiceEntry consulService
        end local 7 // io.vertx.core.Promise registration
        29: .line 204
            iinc 6 /* i */ 1
      StackMap locals: io.vertx.servicediscovery.consul.ConsulServiceImporter java.util.List io.vertx.core.Promise java.util.List java.util.List java.util.List int
      StackMap stack:
        30: iload 6 /* i */
            aload 3 /* serviceEntries */
            invokeinterface java.util.List.size:()I
            if_icmplt 11
        end local 6 // int i
        31: .line 235
            aload 5 /* registrations */
            invokestatic io.vertx.core.CompositeFuture.all:(Ljava/util/List;)Lio/vertx/core/CompositeFuture;
            aload 2 /* future */
            aload 4 /* importedServices */
            invokedynamic handle(Lio/vertx/core/Promise;Ljava/util/List;)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/servicediscovery/consul/ConsulServiceImporter.lambda$17(Lio/vertx/core/Promise;Ljava/util/List;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.CompositeFuture.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/CompositeFuture;
            pop
        end local 5 // java.util.List registrations
        end local 4 // java.util.List importedServices
        end local 3 // java.util.List serviceEntries
        32: .line 243
      StackMap locals: io.vertx.servicediscovery.consul.ConsulServiceImporter java.util.List io.vertx.core.Promise
      StackMap stack:
            return
        end local 2 // io.vertx.core.Promise future
        end local 1 // java.util.List list
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   33     0              this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0   33     1              list  Ljava/util/List<Lio/vertx/ext/consul/ServiceEntry;>;
            0   33     2            future  Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;>;
            7   32     3    serviceEntries  Ljava/util/List<Lio/vertx/ext/consul/ServiceEntry;>;
            8   32     4  importedServices  Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;
            9   32     5     registrations  Ljava/util/List<Lio/vertx/core/Future;>;
           10   31     6                 i  I
           12   29     7      registration  Lio/vertx/core/Promise<Ljava/lang/Void;>;
           13   29     8     consulService  Lio/vertx/ext/consul/ServiceEntry;
           14   29     9                id  Ljava/lang/String;
           15   29    10              name  Ljava/lang/String;
           16   29    11            record  Lio/vertx/servicediscovery/Record;
           17   29    12          imported  Lio/vertx/servicediscovery/consul/ImportedConsulService;
           25   28    13           service  Lio/vertx/servicediscovery/consul/ImportedConsulService;
           26   28    14           promise  Lio/vertx/core/Promise<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;
    Signature: (Ljava/util/List<Lio/vertx/ext/consul/ServiceEntry;>;Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;>;)V
    MethodParameters:
        Name  Flags
      list    
      future  

  private io.vertx.servicediscovery.Record createRecord(io.vertx.ext.consul.Service);
    descriptor: (Lio/vertx/ext/consul/Service;)Lio/vertx/servicediscovery/Record;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=7, args_size=2
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 1 // io.vertx.ext.consul.Service service
         0: .line 246
            aload 1 /* service */
            invokevirtual io.vertx.ext.consul.Service.getAddress:()Ljava/lang/String;
            astore 2 /* address */
        start local 2 // java.lang.String address
         1: .line 247
            aload 1 /* service */
            invokevirtual io.vertx.ext.consul.Service.getPort:()I
            istore 3 /* port */
        start local 3 // int port
         2: .line 249
            aload 1 /* service */
            invokevirtual io.vertx.ext.consul.Service.toJson:()Lio/vertx/core/json/JsonObject;
            astore 4 /* metadata */
        start local 4 // io.vertx.core.json.JsonObject metadata
         3: .line 250
            aload 1 /* service */
            invokevirtual io.vertx.ext.consul.Service.getTags:()Ljava/util/List;
            ifnull 5
         4: .line 251
            aload 1 /* service */
            invokevirtual io.vertx.ext.consul.Service.getTags:()Ljava/util/List;
            aload 4 /* metadata */
            invokedynamic accept(Lio/vertx/core/json/JsonObject;)Ljava/util/function/Consumer;
              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/servicediscovery/consul/ConsulServiceImporter.lambda$18(Lio/vertx/core/json/JsonObject;Ljava/lang/String;)V (6)
                  (Ljava/lang/String;)V
            invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
         5: .line 254
      StackMap locals: java.lang.String int io.vertx.core.json.JsonObject
      StackMap stack:
            new io.vertx.servicediscovery.Record
            dup
            invokespecial io.vertx.servicediscovery.Record.<init>:()V
         6: .line 255
            aload 1 /* service */
            invokevirtual io.vertx.ext.consul.Service.getName:()Ljava/lang/String;
            invokevirtual io.vertx.servicediscovery.Record.setName:(Ljava/lang/String;)Lio/vertx/servicediscovery/Record;
         7: .line 256
            aload 4 /* metadata */
            invokevirtual io.vertx.servicediscovery.Record.setMetadata:(Lio/vertx/core/json/JsonObject;)Lio/vertx/servicediscovery/Record;
         8: .line 254
            astore 5 /* record */
        start local 5 // io.vertx.servicediscovery.Record record
         9: .line 259
            aload 5 /* record */
            ldc "unknown"
            invokevirtual io.vertx.servicediscovery.Record.setType:(Ljava/lang/String;)Lio/vertx/servicediscovery/Record;
            pop
        10: .line 260
            invokestatic io.vertx.servicediscovery.impl.ServiceTypes.all:()Ljava/util/Iterator;
            aload 4 /* metadata */
            aload 5 /* record */
            invokedynamic accept(Lio/vertx/core/json/JsonObject;Lio/vertx/servicediscovery/Record;)Ljava/util/function/Consumer;
              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/servicediscovery/consul/ConsulServiceImporter.lambda$19(Lio/vertx/core/json/JsonObject;Lio/vertx/servicediscovery/Record;Lio/vertx/servicediscovery/spi/ServiceType;)V (6)
                  (Lio/vertx/servicediscovery/spi/ServiceType;)V
            invokeinterface java.util.Iterator.forEachRemaining:(Ljava/util/function/Consumer;)V
        11: .line 266
            new io.vertx.core.json.JsonObject
            dup
            invokespecial io.vertx.core.json.JsonObject.<init>:()V
            astore 6 /* location */
        start local 6 // io.vertx.core.json.JsonObject location
        12: .line 267
            aload 6 /* location */
            ldc "host"
            aload 2 /* address */
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
        13: .line 268
            aload 6 /* location */
            ldc "port"
            iload 3 /* port */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
        14: .line 271
            aload 5 /* record */
            invokevirtual io.vertx.servicediscovery.Record.getType:()Ljava/lang/String;
            ldc "http-endpoint"
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifeq 18
        15: .line 272
            aload 4 /* metadata */
            ldc "ssl"
            iconst_0
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokevirtual io.vertx.core.json.JsonObject.getBoolean:(Ljava/lang/String;Ljava/lang/Boolean;)Ljava/lang/Boolean;
            invokevirtual java.lang.Boolean.booleanValue:()Z
            ifeq 17
        16: .line 273
            aload 6 /* location */
            ldc "ssl"
            iconst_1
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            pop
        17: .line 275
      StackMap locals: io.vertx.servicediscovery.Record io.vertx.core.json.JsonObject
      StackMap stack:
            new io.vertx.servicediscovery.types.HttpLocation
            dup
            aload 6 /* location */
            invokespecial io.vertx.servicediscovery.types.HttpLocation.<init>:(Lio/vertx/core/json/JsonObject;)V
            invokevirtual io.vertx.servicediscovery.types.HttpLocation.toJson:()Lio/vertx/core/json/JsonObject;
            astore 6 /* location */
        18: .line 278
      StackMap locals:
      StackMap stack:
            aload 5 /* record */
            aload 6 /* location */
            invokevirtual io.vertx.servicediscovery.Record.setLocation:(Lio/vertx/core/json/JsonObject;)Lio/vertx/servicediscovery/Record;
            pop
        19: .line 279
            aload 5 /* record */
            areturn
        end local 6 // io.vertx.core.json.JsonObject location
        end local 5 // io.vertx.servicediscovery.Record record
        end local 4 // io.vertx.core.json.JsonObject metadata
        end local 3 // int port
        end local 2 // java.lang.String address
        end local 1 // io.vertx.ext.consul.Service service
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   20     0      this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0   20     1   service  Lio/vertx/ext/consul/Service;
            1   20     2   address  Ljava/lang/String;
            2   20     3      port  I
            3   20     4  metadata  Lio/vertx/core/json/JsonObject;
            9   20     5    record  Lio/vertx/servicediscovery/Record;
           12   20     6  location  Lio/vertx/core/json/JsonObject;
    MethodParameters:
         Name  Flags
      service  

  private synchronized io.vertx.servicediscovery.consul.ImportedConsulService getImportedServiceById(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/vertx/servicediscovery/consul/ImportedConsulService;
    flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=4, args_size=2
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 1 // java.lang.String id
         0: .line 283
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.imports:Ljava/util/List;
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 3
            goto 4
      StackMap locals: io.vertx.servicediscovery.consul.ConsulServiceImporter java.lang.String top java.util.Iterator
      StackMap stack:
         1: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast io.vertx.servicediscovery.consul.ImportedConsulService
            astore 2 /* svc */
        start local 2 // io.vertx.servicediscovery.consul.ImportedConsulService svc
         2: .line 284
            aload 2 /* svc */
            invokevirtual io.vertx.servicediscovery.consul.ImportedConsulService.id:()Ljava/lang/String;
            aload 1 /* id */
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifeq 4
         3: .line 285
            aload 2 /* svc */
            areturn
        end local 2 // io.vertx.servicediscovery.consul.ImportedConsulService svc
         4: .line 283
      StackMap locals:
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 1
         5: .line 288
            aconst_null
            areturn
        end local 1 // java.lang.String id
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    6     1    id  Ljava/lang/String;
            2    4     2   svc  Lio/vertx/servicediscovery/consul/ImportedConsulService;
    MethodParameters:
      Name  Flags
      id    

  public synchronized void close(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 1 // io.vertx.core.Handler completionHandler
         0: .line 293
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.scanTask:J
            ldc -1
            lcmp
            ifeq 2
         1: .line 294
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.vertx:Lio/vertx/core/Vertx;
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.scanTask:J
            invokeinterface io.vertx.core.Vertx.cancelTimer:(J)Z
            pop
         2: .line 297
      StackMap locals:
      StackMap stack:
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 2 /* list */
        start local 2 // java.util.List list
         3: .line 298
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.imports:Ljava/util/List;
            aload 0 /* this */
            aload 2 /* list */
            invokedynamic accept(Lio/vertx/servicediscovery/consul/ConsulServiceImporter;Ljava/util/List;)Ljava/util/function/Consumer;
              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/servicediscovery/consul/ConsulServiceImporter.lambda$20(Ljava/util/List;Lio/vertx/servicediscovery/consul/ImportedConsulService;)V (7)
                  (Lio/vertx/servicediscovery/consul/ImportedConsulService;)V
            invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
         4: .line 311
            aload 2 /* list */
            invokestatic io.vertx.core.CompositeFuture.all:(Ljava/util/List;)Lio/vertx/core/CompositeFuture;
            aload 0 /* this */
            aload 1 /* completionHandler */
            invokedynamic handle(Lio/vertx/servicediscovery/consul/ConsulServiceImporter;Lio/vertx/core/Handler;)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/servicediscovery/consul/ConsulServiceImporter.lambda$22(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.CompositeFuture.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/CompositeFuture;
            pop
         5: .line 322
            return
        end local 2 // java.util.List list
        end local 1 // io.vertx.core.Handler completionHandler
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    6     0               this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    6     1  completionHandler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
            3    6     2               list  Ljava/util/List<Lio/vertx/core/Future;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)V
    MethodParameters:
                   Name  Flags
      completionHandler  

  private synchronized void clearImportedServices();
    descriptor: ()V
    flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
         0: .line 325
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.imports:Ljava/util/List;
            invokeinterface java.util.List.clear:()V
         1: .line 326
            return
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;

  private void lambda$0(io.vertx.core.json.JsonObject, io.vertx.core.Vertx, io.vertx.core.Promise, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/json/JsonObject;Lio/vertx/core/Vertx;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=6, locals=6, args_size=5
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 4 // io.vertx.core.AsyncResult ar
         0: .line 76
            aload 4 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 6
         1: .line 77
            aload 1
            ldc "scan-period"
            sipush 2000
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokevirtual io.vertx.core.json.JsonObject.getInteger:(Ljava/lang/String;Ljava/lang/Integer;)Ljava/lang/Integer;
            astore 5 /* period */
        start local 5 // java.lang.Integer period
         2: .line 78
            aload 5 /* period */
            invokevirtual java.lang.Integer.intValue:()I
            ifeq 4
         3: .line 79
            aload 0 /* this */
            aload 2
            aload 5 /* period */
            invokevirtual java.lang.Integer.intValue:()I
            i2l
            aload 0 /* this */
            aload 4 /* ar */
            invokedynamic handle(Lio/vertx/servicediscovery/consul/ConsulServiceImporter;Lio/vertx/core/AsyncResult;)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/servicediscovery/consul/ConsulServiceImporter.lambda$1(Lio/vertx/core/AsyncResult;Ljava/lang/Long;)V (7)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.Vertx.setPeriodic:(JLio/vertx/core/Handler;)J
            putfield io.vertx.servicediscovery.consul.ConsulServiceImporter.scanTask:J
         4: .line 89
      StackMap locals: java.lang.Integer
      StackMap stack:
            aload 3
            invokeinterface io.vertx.core.Promise.complete:()V
        end local 5 // java.lang.Integer period
         5: .line 90
            goto 7
         6: .line 91
      StackMap locals:
      StackMap stack:
            aload 3
            aload 4 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
         7: .line 93
      StackMap locals:
      StackMap stack:
            return
        end local 4 // io.vertx.core.AsyncResult ar
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    8     0    this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    8     4      ar  Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;>;
            2    5     5  period  Ljava/lang/Integer;

  private static void lambda$3(io.vertx.core.Promise, java.lang.Throwable);
    descriptor: (Lio/vertx/core/Promise;Ljava/lang/Throwable;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // java.lang.Throwable t
         0: .line 100
            aload 0
            ifnull 3
         1: .line 101
            aload 0
            aload 1 /* t */
            invokeinterface io.vertx.core.Promise.tryFail:(Ljava/lang/Throwable;)Z
            pop
         2: .line 102
            goto 4
         3: .line 103
      StackMap locals:
      StackMap stack:
            getstatic io.vertx.servicediscovery.consul.ConsulServiceImporter.LOGGER:Lio/vertx/core/impl/logging/Logger;
            aload 1 /* t */
            invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;)V
         4: .line 105
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.Throwable t
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     1     t  Ljava/lang/Throwable;

  private void lambda$4(io.vertx.core.Promise, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 2 // io.vertx.core.AsyncResult ar
         0: .line 110
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 111
            aload 0 /* this */
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.ext.consul.ServiceList
            aload 1
            invokevirtual io.vertx.servicediscovery.consul.ConsulServiceImporter.retrieveIndividualServices:(Lio/vertx/ext/consul/ServiceList;Lio/vertx/core/Promise;)V
         2: .line 112
            goto 4
         3: .line 113
      StackMap locals:
      StackMap stack:
            aload 1
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
         4: .line 115
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult ar
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    5     2    ar  Lio/vertx/core/AsyncResult<Lio/vertx/ext/consul/ServiceList;>;

  private void lambda$5(io.vertx.core.Promise, java.util.List, io.vertx.ext.consul.Service);
    descriptor: (Lio/vertx/core/Promise;Ljava/util/List;Lio/vertx/ext/consul/Service;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=6, locals=5, args_size=4
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 3 // io.vertx.ext.consul.Service service
         0: .line 132
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 4 /* promise */
        start local 4 // io.vertx.core.Promise promise
         1: .line 133
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.client:Lio/vertx/ext/consul/ConsulClient;
            aload 3 /* service */
            invokevirtual io.vertx.ext.consul.Service.getName:()Ljava/lang/String;
            iconst_0
            aload 0 /* this */
            aload 4 /* promise */
            aload 1
            invokedynamic handle(Lio/vertx/servicediscovery/consul/ConsulServiceImporter;Lio/vertx/core/Promise;Lio/vertx/core/Promise;)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/servicediscovery/consul/ConsulServiceImporter.lambda$6(Lio/vertx/core/Promise;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.ext.consul.ConsulClient.healthServiceNodes:(Ljava/lang/String;ZLio/vertx/core/Handler;)Lio/vertx/ext/consul/ConsulClient;
            pop
         2: .line 141
            aload 2
            aload 4 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 4 // io.vertx.core.Promise promise
         3: .line 142
            return
        end local 3 // io.vertx.ext.consul.Service service
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    4     3  service  Lio/vertx/ext/consul/Service;
            1    3     4  promise  Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;>;

  private void lambda$7(java.util.List, io.vertx.core.Promise, io.vertx.core.AsyncResult);
    descriptor: (Ljava/util/List;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=9, args_size=4
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 3 // io.vertx.core.AsyncResult ar
         0: .line 145
            aload 3 /* ar */
            invokeinterface io.vertx.core.AsyncResult.failed:()Z
            ifeq 3
         1: .line 146
            getstatic io.vertx.servicediscovery.consul.ConsulServiceImporter.LOGGER:Lio/vertx/core/impl/logging/Logger;
            ldc "Fail to retrieve the services from consul"
            aload 3 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
         2: .line 147
            goto 19
         3: .line 149
      StackMap locals:
      StackMap stack:
            aload 1
            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/servicediscovery/consul/ConsulServiceImporter.lambda$8(Lio/vertx/core/Future;)Ljava/util/List; (6)
                  (Lio/vertx/core/Future;)Ljava/util/List;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
         4: .line 150
            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/Collection.stream()Ljava/util/stream/Stream; (9 itf)
                  (Ljava/util/List;)Ljava/util/stream/Stream;
            invokeinterface java.util.stream.Stream.flatMap:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
         5: .line 151
            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
         6: .line 148
            astore 4 /* services */
        start local 4 // java.util.List services
         7: .line 153
            aload 4 /* services */
            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/servicediscovery/consul/ImportedConsulService.id()Ljava/lang/String; (5)
                  (Lio/vertx/servicediscovery/consul/ImportedConsulService;)Ljava/lang/String;
            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
            astore 5 /* retrievedIds */
        start local 5 // java.util.List retrievedIds
         8: .line 155
            aload 0 /* this */
            dup
            astore 6
            monitorenter
         9: .line 157
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.imports:Ljava/util/List;
            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/servicediscovery/consul/ImportedConsulService.id()Ljava/lang/String; (5)
                  (Lio/vertx/servicediscovery/consul/ImportedConsulService;)Ljava/lang/String;
            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
            astore 7 /* existingIds */
        start local 7 // java.util.List existingIds
        10: .line 159
            getstatic io.vertx.servicediscovery.consul.ConsulServiceImporter.LOGGER:Lio/vertx/core/impl/logging/Logger;
            new java.lang.StringBuilder
            dup
            ldc "Imported services: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 7 /* existingIds */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            ldc ", Retrieved services form Consul: "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 5 /* retrievedIds */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokeinterface io.vertx.core.impl.logging.Logger.trace:(Ljava/lang/Object;)V
        11: .line 161
            aload 4 /* services */
            aload 0 /* this */
            aload 7 /* existingIds */
            invokedynamic accept(Lio/vertx/servicediscovery/consul/ConsulServiceImporter;Ljava/util/List;)Ljava/util/function/Consumer;
              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/servicediscovery/consul/ConsulServiceImporter.lambda$12(Ljava/util/List;Lio/vertx/servicediscovery/consul/ImportedConsulService;)V (7)
                  (Lio/vertx/servicediscovery/consul/ImportedConsulService;)V
            invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
        12: .line 170
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 8 /* toRemove */
        start local 8 // java.util.List toRemove
        13: .line 171
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.imports:Ljava/util/List;
            aload 0 /* this */
            aload 5 /* retrievedIds */
            aload 8 /* toRemove */
            invokedynamic accept(Lio/vertx/servicediscovery/consul/ConsulServiceImporter;Ljava/util/List;Ljava/util/List;)Ljava/util/function/Consumer;
              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/servicediscovery/consul/ConsulServiceImporter.lambda$13(Ljava/util/List;Ljava/util/List;Lio/vertx/servicediscovery/consul/ImportedConsulService;)V (7)
                  (Lio/vertx/servicediscovery/consul/ImportedConsulService;)V
            invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
        14: .line 179
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.imports:Ljava/util/List;
            aload 8 /* toRemove */
            invokeinterface java.util.List.removeAll:(Ljava/util/Collection;)Z
            pop
        end local 8 // java.util.List toRemove
        end local 7 // java.util.List existingIds
        15: .line 155
            aload 6
            monitorexit
        16: goto 19
      StackMap locals: io.vertx.servicediscovery.consul.ConsulServiceImporter java.util.List io.vertx.core.Promise io.vertx.core.AsyncResult java.util.List java.util.List io.vertx.servicediscovery.consul.ConsulServiceImporter
      StackMap stack: java.lang.Throwable
        17: aload 6
            monitorexit
        18: athrow
        end local 5 // java.util.List retrievedIds
        end local 4 // java.util.List services
        19: .line 183
      StackMap locals:
      StackMap stack:
            aload 3 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 22
        20: .line 184
            aload 2
            invokeinterface io.vertx.core.Promise.complete:()V
        21: .line 185
            goto 23
        22: .line 186
      StackMap locals:
      StackMap stack:
            aload 2
            aload 3 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
        23: .line 188
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.AsyncResult ar
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   24     0          this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0   24     3            ar  Lio/vertx/core/AsyncResult<Lio/vertx/core/CompositeFuture;>;
            7   19     4      services  Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;
            8   19     5  retrievedIds  Ljava/util/List<Ljava/lang/String;>;
           10   15     7   existingIds  Ljava/util/List<Ljava/lang/String;>;
           13   15     8      toRemove  Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;
      Exception table:
        from    to  target  type
           9    16      17  any
          17    18      17  any

  private boolean lambda$14(io.vertx.ext.consul.ServiceEntry);
    descriptor: (Lio/vertx/ext/consul/ServiceEntry;)Z
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 1 // io.vertx.ext.consul.ServiceEntry serviceEntry
         0: .line 197
            aload 1 /* serviceEntry */
            invokevirtual io.vertx.ext.consul.ServiceEntry.getChecks:()Ljava/util/List;
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
            aload 0 /* this */
            invokedynamic test(Lio/vertx/servicediscovery/consul/ConsulServiceImporter;)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/servicediscovery/consul/ConsulServiceImporter.lambda$15(Lio/vertx/ext/consul/Check;)Z (7)
                  (Lio/vertx/ext/consul/Check;)Z
            invokeinterface java.util.stream.Stream.allMatch:(Ljava/util/function/Predicate;)Z
            ireturn
        end local 1 // io.vertx.ext.consul.ServiceEntry serviceEntry
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    1     0          this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    1     1  serviceEntry  Lio/vertx/ext/consul/ServiceEntry;

  private static void lambda$16(java.util.List, io.vertx.core.Promise, io.vertx.core.AsyncResult);
    descriptor: (Ljava/util/List;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 2 // io.vertx.core.AsyncResult res
         0: .line 223
            aload 2 /* res */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 4
         1: .line 224
            aload 0
            aload 2 /* res */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.servicediscovery.consul.ImportedConsulService
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         2: .line 225
            aload 1
            invokeinterface io.vertx.core.Promise.complete:()V
         3: .line 226
            goto 5
         4: .line 227
      StackMap locals:
      StackMap stack:
            aload 1
            aload 2 /* res */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
         5: .line 229
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult res
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     2   res  Lio/vertx/core/AsyncResult<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;

  private static void lambda$17(io.vertx.core.Promise, java.util.List, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/Promise;Ljava/util/List;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 2 // io.vertx.core.AsyncResult ar
         0: .line 236
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 237
            aload 0
            aload 1
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
         2: .line 238
            goto 4
         3: .line 239
      StackMap locals:
      StackMap stack:
            aload 0
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
         4: .line 241
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     2    ar  Lio/vertx/core/AsyncResult<Lio/vertx/core/CompositeFuture;>;

  private static void lambda$18(io.vertx.core.json.JsonObject, java.lang.String);
    descriptor: (Lio/vertx/core/json/JsonObject;Ljava/lang/String;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=2
        start local 1 // java.lang.String tag
         0: .line 251
            aload 0
            aload 1 /* tag */
            iconst_1
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokevirtual io.vertx.core.json.JsonObject.put:(Ljava/lang/String;Ljava/lang/Object;)Lio/vertx/core/json/JsonObject;
            return
        end local 1 // java.lang.String tag
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     1   tag  Ljava/lang/String;

  private static void lambda$19(io.vertx.core.json.JsonObject, io.vertx.servicediscovery.Record, io.vertx.servicediscovery.spi.ServiceType);
    descriptor: (Lio/vertx/core/json/JsonObject;Lio/vertx/servicediscovery/Record;Lio/vertx/servicediscovery/spi/ServiceType;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 2 // io.vertx.servicediscovery.spi.ServiceType type
         0: .line 261
            aload 0
            aload 2 /* type */
            invokeinterface io.vertx.servicediscovery.spi.ServiceType.name:()Ljava/lang/String;
            iconst_0
            invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
            invokevirtual io.vertx.core.json.JsonObject.getBoolean:(Ljava/lang/String;Ljava/lang/Boolean;)Ljava/lang/Boolean;
            invokevirtual java.lang.Boolean.booleanValue:()Z
            ifeq 2
         1: .line 262
            aload 1
            aload 2 /* type */
            invokeinterface io.vertx.servicediscovery.spi.ServiceType.name:()Ljava/lang/String;
            invokevirtual io.vertx.servicediscovery.Record.setType:(Ljava/lang/String;)Lio/vertx/servicediscovery/Record;
            pop
         2: .line 264
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.servicediscovery.spi.ServiceType type
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     2  type  Lio/vertx/servicediscovery/spi/ServiceType;

  private void lambda$20(java.util.List, io.vertx.servicediscovery.consul.ImportedConsulService);
    descriptor: (Ljava/util/List;Lio/vertx/servicediscovery/consul/ImportedConsulService;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=4, args_size=3
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 2 // io.vertx.servicediscovery.consul.ImportedConsulService imported
         0: .line 299
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 3 /* promise */
        start local 3 // io.vertx.core.Promise promise
         1: .line 300
            aload 3 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            aload 2 /* imported */
            aload 1
            invokedynamic handle(Lio/vertx/servicediscovery/consul/ImportedConsulService;Ljava/util/List;)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/servicediscovery/consul/ConsulServiceImporter.lambda$21(Lio/vertx/servicediscovery/consul/ImportedConsulService;Ljava/util/List;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         2: .line 308
            aload 2 /* imported */
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
            aload 3 /* promise */
            invokevirtual io.vertx.servicediscovery.consul.ImportedConsulService.unregister:(Lio/vertx/servicediscovery/spi/ServicePublisher;Lio/vertx/core/Promise;)V
        end local 3 // io.vertx.core.Promise promise
         3: .line 309
            return
        end local 2 // io.vertx.servicediscovery.consul.ImportedConsulService imported
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    4     0      this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    4     2  imported  Lio/vertx/servicediscovery/consul/ImportedConsulService;
            1    3     3   promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;

  private void lambda$22(io.vertx.core.Handler, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 2 // io.vertx.core.AsyncResult ar
         0: .line 312
            aload 0 /* this */
            invokevirtual io.vertx.servicediscovery.consul.ConsulServiceImporter.clearImportedServices:()V
         1: .line 313
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 4
         2: .line 314
            getstatic io.vertx.servicediscovery.consul.ConsulServiceImporter.LOGGER:Lio/vertx/core/impl/logging/Logger;
            new java.lang.StringBuilder
            dup
            ldc "Successfully closed the service importer "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokeinterface io.vertx.core.impl.logging.Logger.info:(Ljava/lang/Object;)V
         3: .line 315
            goto 5
         4: .line 316
      StackMap locals:
      StackMap stack:
            getstatic io.vertx.servicediscovery.consul.ConsulServiceImporter.LOGGER:Lio/vertx/core/impl/logging/Logger;
            new java.lang.StringBuilder
            dup
            ldc "A failure has been caught while stopping "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
         5: .line 318
      StackMap locals:
      StackMap stack:
            aload 1
            ifnull 7
         6: .line 319
            aload 1
            aconst_null
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         7: .line 321
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult ar
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    8     0  this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    8     2    ar  Lio/vertx/core/AsyncResult<Lio/vertx/core/CompositeFuture;>;

  private void lambda$1(io.vertx.core.AsyncResult, java.lang.Long);
    descriptor: (Lio/vertx/core/AsyncResult;Ljava/lang/Long;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 2 // java.lang.Long l
         0: .line 80
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 3 /* promise */
        start local 3 // io.vertx.core.Promise promise
         1: .line 81
            aload 3 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            aload 1
            invokedynamic handle(Lio/vertx/core/AsyncResult;)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/servicediscovery/consul/ConsulServiceImporter.lambda$2(Lio/vertx/core/AsyncResult;Lio/vertx/core/AsyncResult;)V (6)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         2: .line 86
            aload 0 /* this */
            aload 3 /* promise */
            invokevirtual io.vertx.servicediscovery.consul.ConsulServiceImporter.retrieveServicesFromConsul:(Lio/vertx/core/Promise;)V
        end local 3 // io.vertx.core.Promise promise
         3: .line 87
            return
        end local 2 // java.lang.Long l
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    4     2        l  Ljava/lang/Long;
            1    3     3  promise  Lio/vertx/core/Promise<Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;>;

  private void lambda$6(io.vertx.core.Promise, io.vertx.core.Promise, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/Promise;Lio/vertx/core/Promise;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 3 // io.vertx.core.AsyncResult ar
         0: .line 134
            aload 3 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 3
         1: .line 135
            aload 0 /* this */
            aload 3 /* ar */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.ext.consul.ServiceEntryList
            invokevirtual io.vertx.ext.consul.ServiceEntryList.getList:()Ljava/util/List;
            aload 1
            invokevirtual io.vertx.servicediscovery.consul.ConsulServiceImporter.importService:(Ljava/util/List;Lio/vertx/core/Promise;)V
         2: .line 136
            goto 4
         3: .line 137
      StackMap locals:
      StackMap stack:
            aload 2
            aload 3 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/Throwable;)V
         4: .line 139
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.AsyncResult ar
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    5     3    ar  Lio/vertx/core/AsyncResult<Lio/vertx/ext/consul/ServiceEntryList;>;

  private static java.util.List lambda$8(io.vertx.core.Future);
    descriptor: (Lio/vertx/core/Future;)Ljava/util/List;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.core.Future future
         0: .line 149
            aload 0 /* future */
            invokeinterface io.vertx.core.Future.result:()Ljava/lang/Object;
            checkcast java.util.List
            areturn
        end local 0 // io.vertx.core.Future future
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  future  Lio/vertx/core/Future;

  private void lambda$12(java.util.List, io.vertx.servicediscovery.consul.ImportedConsulService);
    descriptor: (Ljava/util/List;Lio/vertx/servicediscovery/consul/ImportedConsulService;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=3
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 2 // io.vertx.servicediscovery.consul.ImportedConsulService svc
         0: .line 162
            aload 2 /* svc */
            invokevirtual io.vertx.servicediscovery.consul.ImportedConsulService.id:()Ljava/lang/String;
            astore 3 /* id */
        start local 3 // java.lang.String id
         1: .line 164
            aload 1
            aload 3 /* id */
            invokeinterface java.util.List.contains:(Ljava/lang/Object;)Z
            ifne 4
         2: .line 165
            getstatic io.vertx.servicediscovery.consul.ConsulServiceImporter.LOGGER:Lio/vertx/core/impl/logging/Logger;
            new java.lang.StringBuilder
            dup
            ldc "Imported service: "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 3 /* id */
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokeinterface io.vertx.core.impl.logging.Logger.info:(Ljava/lang/Object;)V
         3: .line 166
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.imports:Ljava/util/List;
            aload 2 /* svc */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 3 // java.lang.String id
         4: .line 168
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.servicediscovery.consul.ImportedConsulService svc
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    5     2   svc  Lio/vertx/servicediscovery/consul/ImportedConsulService;
            1    4     3    id  Ljava/lang/String;

  private void lambda$13(java.util.List, java.util.List, io.vertx.servicediscovery.consul.ImportedConsulService);
    descriptor: (Ljava/util/List;Ljava/util/List;Lio/vertx/servicediscovery/consul/ImportedConsulService;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=4, args_size=4
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 3 // io.vertx.servicediscovery.consul.ImportedConsulService svc
         0: .line 172
            aload 1
            aload 3 /* svc */
            invokevirtual io.vertx.servicediscovery.consul.ImportedConsulService.id:()Ljava/lang/String;
            invokeinterface java.util.List.contains:(Ljava/lang/Object;)Z
            ifne 4
         1: .line 173
            getstatic io.vertx.servicediscovery.consul.ConsulServiceImporter.LOGGER:Lio/vertx/core/impl/logging/Logger;
            new java.lang.StringBuilder
            dup
            ldc "Unregistering "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 3 /* svc */
            invokevirtual io.vertx.servicediscovery.consul.ImportedConsulService.id:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokeinterface io.vertx.core.impl.logging.Logger.info:(Ljava/lang/Object;)V
         2: .line 174
            aload 2
            aload 3 /* svc */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         3: .line 175
            aload 3 /* svc */
            aload 0 /* this */
            getfield io.vertx.servicediscovery.consul.ConsulServiceImporter.publisher:Lio/vertx/servicediscovery/spi/ServicePublisher;
            aconst_null
            invokevirtual io.vertx.servicediscovery.consul.ImportedConsulService.unregister:(Lio/vertx/servicediscovery/spi/ServicePublisher;Lio/vertx/core/Promise;)V
         4: .line 177
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.servicediscovery.consul.ImportedConsulService svc
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    5     3   svc  Lio/vertx/servicediscovery/consul/ImportedConsulService;

  private boolean lambda$15(io.vertx.ext.consul.Check);
    descriptor: (Lio/vertx/ext/consul/Check;)Z
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
        start local 1 // io.vertx.ext.consul.Check check
         0: .line 197
            aload 0 /* this */
            aload 1 /* check */
            invokevirtual io.vertx.ext.consul.Check.getStatus:()Lio/vertx/ext/consul/CheckStatus;
            invokevirtual io.vertx.servicediscovery.consul.ConsulServiceImporter.isCheckOK:(Lio/vertx/ext/consul/CheckStatus;)Z
            ireturn
        end local 1 // io.vertx.ext.consul.Check check
        end local 0 // io.vertx.servicediscovery.consul.ConsulServiceImporter this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0   this  Lio/vertx/servicediscovery/consul/ConsulServiceImporter;
            0    1     1  check  Lio/vertx/ext/consul/Check;

  private static void lambda$21(io.vertx.servicediscovery.consul.ImportedConsulService, java.util.List, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/servicediscovery/consul/ImportedConsulService;Ljava/util/List;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=3
        start local 2 // io.vertx.core.AsyncResult ar
         0: .line 301
            getstatic io.vertx.servicediscovery.consul.ConsulServiceImporter.LOGGER:Lio/vertx/core/impl/logging/Logger;
            new java.lang.StringBuilder
            dup
            ldc "Unregistering "
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0
            invokevirtual io.vertx.servicediscovery.consul.ImportedConsulService.name:()Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            invokeinterface io.vertx.core.impl.logging.Logger.info:(Ljava/lang/Object;)V
         1: .line 302
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 4
         2: .line 303
            aload 1
            invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         3: .line 304
            goto 5
         4: .line 305
      StackMap locals:
      StackMap stack:
            aload 1
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokestatic io.vertx.core.Future.failedFuture:(Ljava/lang/Throwable;)Lio/vertx/core/Future;
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         5: .line 307
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult ar
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     2    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static void lambda$2(io.vertx.core.AsyncResult, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/AsyncResult;Lio/vertx/core/AsyncResult;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=2, args_size=2
        start local 1 // io.vertx.core.AsyncResult ar2
         0: .line 82
            aload 1 /* ar2 */
            invokeinterface io.vertx.core.AsyncResult.failed:()Z
            ifeq 2
         1: .line 83
            getstatic io.vertx.servicediscovery.consul.ConsulServiceImporter.LOGGER:Lio/vertx/core/impl/logging/Logger;
            ldc "Consul importation has failed"
            aload 0
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.impl.logging.Logger.warn:(Ljava/lang/Object;Ljava/lang/Throwable;)V
         2: .line 85
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.core.AsyncResult ar2
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     1   ar2  Lio/vertx/core/AsyncResult<Ljava/util/List<Lio/vertx/servicediscovery/consul/ImportedConsulService;>;>;
}
SourceFile: "ConsulServiceImporter.java"
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles