http://nexus.sonatype.org/oss-repository-hosting.html/vertx-parent/vertx-ext/vertx-ext-parent/vertx-cassandra-client: Sonatype helps open source projects to set up Maven repositories on https://oss.sonatype.org/ (Eclipse) 
public class io.vertx.cassandra.impl.CassandraClientImpl implements io.vertx.cassandra.CassandraClient
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.cassandra.impl.CassandraClientImpl
  super_class: java.lang.Object
{
  static final java.lang.String HOLDERS_LOCAL_MAP_NAME;
    descriptor: Ljava/lang/String;
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    ConstantValue: "__vertx.cassandraClient.sessionHolders"

  final io.vertx.core.impl.VertxInternal vertx;
    descriptor: Lio/vertx/core/impl/VertxInternal;
    flags: (0x0010) ACC_FINAL

  private final java.lang.String clientName;
    descriptor: Ljava/lang/String;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final io.vertx.cassandra.CassandraClientOptions options;
    descriptor: Lio/vertx/cassandra/CassandraClientOptions;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final java.util.Map<java.lang.String, io.vertx.cassandra.impl.SessionHolder> holders;
    descriptor: Ljava/util/Map;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Ljava/util/Map<Ljava/lang/String;Lio/vertx/cassandra/impl/SessionHolder;>;

  private final io.vertx.core.impl.ContextInternal creatingContext;
    descriptor: Lio/vertx/core/impl/ContextInternal;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private boolean closed;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  public void <init>(io.vertx.core.Vertx, java.lang.String, io.vertx.cassandra.CassandraClientOptions);
    descriptor: (Lio/vertx/core/Vertx;Ljava/lang/String;Lio/vertx/cassandra/CassandraClientOptions;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // io.vertx.core.Vertx vertx
        start local 2 // java.lang.String clientName
        start local 3 // io.vertx.cassandra.CassandraClientOptions options
         0: .line 59
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 60
            aload 1 /* vertx */
            ldc "vertx"
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         2: .line 61
            aload 2 /* clientName */
            ldc "clientName"
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         3: .line 62
            aload 3 /* options */
            ldc "options"
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         4: .line 63
            aload 0 /* this */
            aload 1 /* vertx */
            checkcast io.vertx.core.impl.VertxInternal
            putfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
         5: .line 64
            aload 0 /* this */
            aload 2 /* clientName */
            putfield io.vertx.cassandra.impl.CassandraClientImpl.clientName:Ljava/lang/String;
         6: .line 65
            aload 0 /* this */
            aload 3 /* options */
            putfield io.vertx.cassandra.impl.CassandraClientImpl.options:Lio/vertx/cassandra/CassandraClientOptions;
         7: .line 66
            aload 0 /* this */
            aload 1 /* vertx */
            checkcast io.vertx.core.impl.VertxInternal
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            putfield io.vertx.cassandra.impl.CassandraClientImpl.creatingContext:Lio/vertx/core/impl/ContextInternal;
         8: .line 67
            aload 0 /* this */
            aload 1 /* vertx */
            invokeinterface io.vertx.core.Vertx.sharedData:()Lio/vertx/core/shareddata/SharedData;
            ldc "__vertx.cassandraClient.sessionHolders"
            invokeinterface io.vertx.core.shareddata.SharedData.getLocalMap:(Ljava/lang/String;)Lio/vertx/core/shareddata/LocalMap;
            putfield io.vertx.cassandra.impl.CassandraClientImpl.holders:Ljava/util/Map;
         9: .line 68
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.holders:Ljava/util/Map;
            aload 2 /* clientName */
            invokedynamic apply()Ljava/util/function/BiFunction;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
                  io/vertx/cassandra/impl/CassandraClientImpl.lambda$0(Ljava/lang/String;Lio/vertx/cassandra/impl/SessionHolder;)Lio/vertx/cassandra/impl/SessionHolder; (6)
                  (Ljava/lang/String;Lio/vertx/cassandra/impl/SessionHolder;)Lio/vertx/cassandra/impl/SessionHolder;
            invokeinterface java.util.Map.compute:(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object;
            checkcast io.vertx.cassandra.impl.SessionHolder
            pop
        10: .line 69
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.creatingContext:Lio/vertx/core/impl/ContextInternal;
            aload 0 /* this */
            invokedynamic close(Lio/vertx/cassandra/impl/CassandraClientImpl;)Lio/vertx/core/Closeable;
              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:
                  (Lio/vertx/core/Promise;)V
                  io/vertx/cassandra/impl/CassandraClientImpl.close(Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient; (5)
                  (Lio/vertx/core/Promise;)V
            invokeinterface io.vertx.core.impl.ContextInternal.addCloseHook:(Lio/vertx/core/Closeable;)V
        11: .line 70
            return
        end local 3 // io.vertx.cassandra.CassandraClientOptions options
        end local 2 // java.lang.String clientName
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   12     0        this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0   12     1       vertx  Lio/vertx/core/Vertx;
            0   12     2  clientName  Ljava/lang/String;
            0   12     3     options  Lio/vertx/cassandra/CassandraClientOptions;
    MethodParameters:
            Name  Flags
      vertx       
      clientName  
      options     

  public synchronized boolean isConnected();
    descriptor: ()Z
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
         0: .line 74
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.closed:Z
            ifeq 2
         1: .line 75
            iconst_0
            ireturn
         2: .line 77
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.holders:Ljava/util/Map;
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.clientName:Ljava/lang/String;
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.cassandra.impl.SessionHolder
            getfield io.vertx.cassandra.impl.SessionHolder.session:Lcom/datastax/oss/driver/api/core/CqlSession;
            astore 1 /* s */
        start local 1 // com.datastax.oss.driver.api.core.session.Session s
         3: .line 78
            aload 1 /* s */
            ifnull 4
            aload 1 /* s */
            invokeinterface com.datastax.oss.driver.api.core.session.Session.isClosed:()Z
            ifne 4
            iconst_1
            ireturn
      StackMap locals: com.datastax.oss.driver.api.core.session.Session
      StackMap stack:
         4: iconst_0
            ireturn
        end local 1 // com.datastax.oss.driver.api.core.session.Session s
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            3    5     1     s  Lcom/datastax/oss/driver/api/core/session/Session;

  public io.vertx.cassandra.CassandraClient executeWithFullFetch(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<com.datastax.oss.driver.api.core.cql.Row>>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // java.lang.String query
        start local 2 // io.vertx.core.Handler resultHandler
         0: .line 83
            aload 0 /* this */
            aload 1 /* query */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.executeWithFullFetch:(Ljava/lang/String;)Lio/vertx/core/Future;
            astore 3 /* listFuture */
        start local 3 // io.vertx.core.Future listFuture
         1: .line 84
            aload 3 /* listFuture */
            aload 2 /* resultHandler */
            invokestatic io.vertx.cassandra.impl.Util.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
         2: .line 85
            aload 0 /* this */
            areturn
        end local 3 // io.vertx.core.Future listFuture
        end local 2 // io.vertx.core.Handler resultHandler
        end local 1 // java.lang.String query
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    3     0           this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1          query  Ljava/lang/String;
            0    3     2  resultHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;>;
            1    3     3     listFuture  Lio/vertx/core/Future<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;
    Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;>;)Lio/vertx/cassandra/CassandraClient;
    MethodParameters:
               Name  Flags
      query          
      resultHandler  

  public io.vertx.core.Future<java.util.List<com.datastax.oss.driver.api.core.cql.Row>> executeWithFullFetch(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // java.lang.String query
         0: .line 90
            aload 0 /* this */
            aload 1 /* query */
            invokestatic com.datastax.oss.driver.api.core.cql.SimpleStatement.newInstance:(Ljava/lang/String;)Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.executeWithFullFetch:(Lcom/datastax/oss/driver/api/core/cql/Statement;)Lio/vertx/core/Future;
            areturn
        end local 1 // java.lang.String query
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0   this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    1     1  query  Ljava/lang/String;
    Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;
    MethodParameters:
       Name  Flags
      query  

  public io.vertx.cassandra.CassandraClient executeWithFullFetch(com.datastax.oss.driver.api.core.cql.Statement, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<com.datastax.oss.driver.api.core.cql.Row>>>);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/Statement;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        start local 2 // io.vertx.core.Handler resultHandler
         0: .line 95
            aload 0 /* this */
            aload 1 /* statement */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.executeWithFullFetch:(Lcom/datastax/oss/driver/api/core/cql/Statement;)Lio/vertx/core/Future;
            astore 3 /* future */
        start local 3 // io.vertx.core.Future future
         1: .line 96
            aload 3 /* future */
            aload 2 /* resultHandler */
            invokestatic io.vertx.cassandra.impl.Util.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
         2: .line 97
            aload 0 /* this */
            areturn
        end local 3 // io.vertx.core.Future future
        end local 2 // io.vertx.core.Handler resultHandler
        end local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    3     0           this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1      statement  Lcom/datastax/oss/driver/api/core/cql/Statement;
            0    3     2  resultHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;>;
            1    3     3         future  Lio/vertx/core/Future<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;
    Signature: (Lcom/datastax/oss/driver/api/core/cql/Statement;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;>;)Lio/vertx/cassandra/CassandraClient;
    MethodParameters:
               Name  Flags
      statement      
      resultHandler  

  public io.vertx.core.Future<java.util.List<com.datastax.oss.driver.api.core.cql.Row>> executeWithFullFetch(com.datastax.oss.driver.api.core.cql.Statement);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/Statement;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
         0: .line 102
            aload 0 /* this */
            aload 1 /* statement */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.execute:(Lcom/datastax/oss/driver/api/core/cql/Statement;)Lio/vertx/core/Future;
         1: .line 103
            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/cassandra/ResultSet.all()Lio/vertx/core/Future; (9 itf)
                  (Lio/vertx/cassandra/ResultSet;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Future.flatMap:(Ljava/util/function/Function;)Lio/vertx/core/Future;
         2: .line 102
            areturn
        end local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1  statement  Lcom/datastax/oss/driver/api/core/cql/Statement;
    Signature: (Lcom/datastax/oss/driver/api/core/cql/Statement;)Lio/vertx/core/Future<Ljava/util/List<Lcom/datastax/oss/driver/api/core/cql/Row;>;>;
    MethodParameters:
           Name  Flags
      statement  

  public io.vertx.cassandra.CassandraClient execute(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.cassandra.ResultSet>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // java.lang.String query
        start local 2 // io.vertx.core.Handler resultHandler
         0: .line 107
            aload 0 /* this */
            aload 1 /* query */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.execute:(Ljava/lang/String;)Lio/vertx/core/Future;
            astore 3 /* future */
        start local 3 // io.vertx.core.Future future
         1: .line 108
            aload 3 /* future */
            aload 2 /* resultHandler */
            invokestatic io.vertx.cassandra.impl.Util.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
         2: .line 109
            aload 0 /* this */
            areturn
        end local 3 // io.vertx.core.Future future
        end local 2 // io.vertx.core.Handler resultHandler
        end local 1 // java.lang.String query
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    3     0           this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1          query  Ljava/lang/String;
            0    3     2  resultHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/ResultSet;>;>;
            1    3     3         future  Lio/vertx/core/Future<Lio/vertx/cassandra/ResultSet;>;
    Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/ResultSet;>;>;)Lio/vertx/cassandra/CassandraClient;
    MethodParameters:
               Name  Flags
      query          
      resultHandler  

  public io.vertx.core.Future<io.vertx.cassandra.ResultSet> execute(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // java.lang.String query
         0: .line 114
            aload 0 /* this */
            aload 1 /* query */
            invokestatic com.datastax.oss.driver.api.core.cql.SimpleStatement.newInstance:(Ljava/lang/String;)Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.execute:(Lcom/datastax/oss/driver/api/core/cql/Statement;)Lio/vertx/core/Future;
            areturn
        end local 1 // java.lang.String query
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0   this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    1     1  query  Ljava/lang/String;
    Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Lio/vertx/cassandra/ResultSet;>;
    MethodParameters:
       Name  Flags
      query  

  public <R> io.vertx.cassandra.CassandraClient execute(java.lang.String, java.util.stream.Collector<com.datastax.oss.driver.api.core.cql.Row, ?, R>, io.vertx.core.Handler<io.vertx.core.AsyncResult<R>>);
    descriptor: (Ljava/lang/String;Ljava/util/stream/Collector;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=5, args_size=4
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // java.lang.String query
        start local 2 // java.util.stream.Collector collector
        start local 3 // io.vertx.core.Handler asyncResultHandler
         0: .line 119
            aload 0 /* this */
            aload 1 /* query */
            aload 2 /* collector */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.execute:(Ljava/lang/String;Ljava/util/stream/Collector;)Lio/vertx/core/Future;
            astore 4 /* future */
        start local 4 // io.vertx.core.Future future
         1: .line 120
            aload 4 /* future */
            aload 3 /* asyncResultHandler */
            invokestatic io.vertx.cassandra.impl.Util.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
         2: .line 121
            aload 0 /* this */
            areturn
        end local 4 // io.vertx.core.Future future
        end local 3 // io.vertx.core.Handler asyncResultHandler
        end local 2 // java.util.stream.Collector collector
        end local 1 // java.lang.String query
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    3     0                this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1               query  Ljava/lang/String;
            0    3     2           collector  Ljava/util/stream/Collector<Lcom/datastax/oss/driver/api/core/cql/Row;*TR;>;
            0    3     3  asyncResultHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TR;>;>;
            1    3     4              future  Lio/vertx/core/Future<TR;>;
    Signature: <R:Ljava/lang/Object;>(Ljava/lang/String;Ljava/util/stream/Collector<Lcom/datastax/oss/driver/api/core/cql/Row;*TR;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TR;>;>;)Lio/vertx/cassandra/CassandraClient;
    MethodParameters:
                    Name  Flags
      query               
      collector           
      asyncResultHandler  

  public <R> io.vertx.core.Future<R> execute(java.lang.String, java.util.stream.Collector<com.datastax.oss.driver.api.core.cql.Row, ?, R>);
    descriptor: (Ljava/lang/String;Ljava/util/stream/Collector;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // java.lang.String query
        start local 2 // java.util.stream.Collector collector
         0: .line 126
            aload 0 /* this */
            aload 1 /* query */
            invokestatic com.datastax.oss.driver.api.core.cql.SimpleStatement.newInstance:(Ljava/lang/String;)Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;
            aload 2 /* collector */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.execute:(Lcom/datastax/oss/driver/api/core/cql/Statement;Ljava/util/stream/Collector;)Lio/vertx/core/Future;
            areturn
        end local 2 // java.util.stream.Collector collector
        end local 1 // java.lang.String query
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    1     1      query  Ljava/lang/String;
            0    1     2  collector  Ljava/util/stream/Collector<Lcom/datastax/oss/driver/api/core/cql/Row;*TR;>;
    Signature: <R:Ljava/lang/Object;>(Ljava/lang/String;Ljava/util/stream/Collector<Lcom/datastax/oss/driver/api/core/cql/Row;*TR;>;)Lio/vertx/core/Future<TR;>;
    MethodParameters:
           Name  Flags
      query      
      collector  

  public io.vertx.cassandra.CassandraClient execute(com.datastax.oss.driver.api.core.cql.Statement, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.cassandra.ResultSet>>);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/Statement;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        start local 2 // io.vertx.core.Handler resultHandler
         0: .line 131
            aload 0 /* this */
            aload 1 /* statement */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.execute:(Lcom/datastax/oss/driver/api/core/cql/Statement;)Lio/vertx/core/Future;
            astore 3 /* future */
        start local 3 // io.vertx.core.Future future
         1: .line 132
            aload 3 /* future */
            aload 2 /* resultHandler */
            invokestatic io.vertx.cassandra.impl.Util.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
         2: .line 133
            aload 0 /* this */
            areturn
        end local 3 // io.vertx.core.Future future
        end local 2 // io.vertx.core.Handler resultHandler
        end local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    3     0           this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1      statement  Lcom/datastax/oss/driver/api/core/cql/Statement;
            0    3     2  resultHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/ResultSet;>;>;
            1    3     3         future  Lio/vertx/core/Future<Lio/vertx/cassandra/ResultSet;>;
    Signature: (Lcom/datastax/oss/driver/api/core/cql/Statement;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/ResultSet;>;>;)Lio/vertx/cassandra/CassandraClient;
    MethodParameters:
               Name  Flags
      statement      
      resultHandler  

  public io.vertx.core.Future<io.vertx.cassandra.ResultSet> execute(com.datastax.oss.driver.api.core.cql.Statement);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/Statement;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
         0: .line 138
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.getSession:(Lio/vertx/core/impl/ContextInternal;)Lio/vertx/core/Future;
         1: .line 139
            aload 0 /* this */
            aload 1 /* statement */
            invokedynamic apply(Lio/vertx/cassandra/impl/CassandraClientImpl;Lcom/datastax/oss/driver/api/core/cql/Statement;)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/cassandra/impl/CassandraClientImpl.lambda$3(Lcom/datastax/oss/driver/api/core/cql/Statement;Lcom/datastax/oss/driver/api/core/CqlSession;)Lio/vertx/core/Future; (7)
                  (Lcom/datastax/oss/driver/api/core/CqlSession;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Future.flatMap:(Ljava/util/function/Function;)Lio/vertx/core/Future;
         2: .line 140
            aload 0 /* this */
            invokedynamic apply(Lio/vertx/cassandra/impl/CassandraClientImpl;)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/cassandra/impl/CassandraClientImpl.lambda$4(Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;)Lio/vertx/cassandra/ResultSet; (7)
                  (Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;)Lio/vertx/cassandra/ResultSet;
            invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
         3: .line 138
            areturn
        end local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    4     0       this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    4     1  statement  Lcom/datastax/oss/driver/api/core/cql/Statement;
    Signature: (Lcom/datastax/oss/driver/api/core/cql/Statement;)Lio/vertx/core/Future<Lio/vertx/cassandra/ResultSet;>;
    MethodParameters:
           Name  Flags
      statement  

  public <R> io.vertx.cassandra.CassandraClient execute(com.datastax.oss.driver.api.core.cql.Statement, java.util.stream.Collector<com.datastax.oss.driver.api.core.cql.Row, ?, R>, io.vertx.core.Handler<io.vertx.core.AsyncResult<R>>);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/Statement;Ljava/util/stream/Collector;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=5, args_size=4
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        start local 2 // java.util.stream.Collector collector
        start local 3 // io.vertx.core.Handler asyncResultHandler
         0: .line 145
            aload 0 /* this */
            aload 1 /* statement */
            aload 2 /* collector */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.execute:(Lcom/datastax/oss/driver/api/core/cql/Statement;Ljava/util/stream/Collector;)Lio/vertx/core/Future;
            astore 4 /* future */
        start local 4 // io.vertx.core.Future future
         1: .line 146
            aload 4 /* future */
            aload 3 /* asyncResultHandler */
            invokestatic io.vertx.cassandra.impl.Util.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
         2: .line 147
            aload 0 /* this */
            areturn
        end local 4 // io.vertx.core.Future future
        end local 3 // io.vertx.core.Handler asyncResultHandler
        end local 2 // java.util.stream.Collector collector
        end local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    3     0                this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1           statement  Lcom/datastax/oss/driver/api/core/cql/Statement;
            0    3     2           collector  Ljava/util/stream/Collector<Lcom/datastax/oss/driver/api/core/cql/Row;*TR;>;
            0    3     3  asyncResultHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TR;>;>;
            1    3     4              future  Lio/vertx/core/Future<TR;>;
    Signature: <R:Ljava/lang/Object;>(Lcom/datastax/oss/driver/api/core/cql/Statement;Ljava/util/stream/Collector<Lcom/datastax/oss/driver/api/core/cql/Row;*TR;>;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<TR;>;>;)Lio/vertx/cassandra/CassandraClient;
    MethodParameters:
                    Name  Flags
      statement           
      collector           
      asyncResultHandler  

  public <R> io.vertx.core.Future<R> execute(com.datastax.oss.driver.api.core.cql.Statement, java.util.stream.Collector<com.datastax.oss.driver.api.core.cql.Row, ?, R>);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/Statement;Ljava/util/stream/Collector;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        start local 2 // java.util.stream.Collector collector
         0: .line 152
            aload 0 /* this */
            aload 1 /* statement */
            aload 2 /* collector */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.executeAndCollect:(Lcom/datastax/oss/driver/api/core/cql/Statement;Ljava/util/stream/Collector;)Lio/vertx/core/Future;
            areturn
        end local 2 // java.util.stream.Collector collector
        end local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    1     1  statement  Lcom/datastax/oss/driver/api/core/cql/Statement;
            0    1     2  collector  Ljava/util/stream/Collector<Lcom/datastax/oss/driver/api/core/cql/Row;*TR;>;
    Signature: <R:Ljava/lang/Object;>(Lcom/datastax/oss/driver/api/core/cql/Statement;Ljava/util/stream/Collector<Lcom/datastax/oss/driver/api/core/cql/Row;*TR;>;)Lio/vertx/core/Future<TR;>;
    MethodParameters:
           Name  Flags
      statement  
      collector  

  private <C, R> io.vertx.core.Future<R> executeAndCollect(com.datastax.oss.driver.api.core.cql.Statement, java.util.stream.Collector<com.datastax.oss.driver.api.core.cql.Row, C, R>);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/Statement;Ljava/util/stream/Collector;)Lio/vertx/core/Future;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=6, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        start local 2 // java.util.stream.Collector collector
         0: .line 156
            aload 2 /* collector */
            invokeinterface java.util.stream.Collector.supplier:()Ljava/util/function/Supplier;
            invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
            astore 3 /* container */
        start local 3 // java.lang.Object container
         1: .line 157
            aload 2 /* collector */
            invokeinterface java.util.stream.Collector.accumulator:()Ljava/util/function/BiConsumer;
            astore 4 /* accumulator */
        start local 4 // java.util.function.BiConsumer accumulator
         2: .line 158
            aload 2 /* collector */
            invokeinterface java.util.stream.Collector.finisher:()Ljava/util/function/Function;
            astore 5 /* finisher */
        start local 5 // java.util.function.Function finisher
         3: .line 159
            aload 0 /* this */
            aload 1 /* statement */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.queryStream:(Lcom/datastax/oss/driver/api/core/cql/Statement;)Lio/vertx/core/Future;
         4: .line 160
            aload 5 /* finisher */
            aload 3 /* container */
            aload 4 /* accumulator */
            invokedynamic apply(Ljava/util/function/Function;Ljava/lang/Object;Ljava/util/function/BiConsumer;)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/cassandra/impl/CassandraClientImpl.lambda$5(Ljava/util/function/Function;Ljava/lang/Object;Ljava/util/function/BiConsumer;Lio/vertx/cassandra/CassandraRowStream;)Lio/vertx/core/Future; (6)
                  (Lio/vertx/cassandra/CassandraRowStream;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Future.flatMap:(Ljava/util/function/Function;)Lio/vertx/core/Future;
         5: .line 159
            areturn
        end local 5 // java.util.function.Function finisher
        end local 4 // java.util.function.BiConsumer accumulator
        end local 3 // java.lang.Object container
        end local 2 // java.util.stream.Collector collector
        end local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    6     0         this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    6     1    statement  Lcom/datastax/oss/driver/api/core/cql/Statement;
            0    6     2    collector  Ljava/util/stream/Collector<Lcom/datastax/oss/driver/api/core/cql/Row;TC;TR;>;
            1    6     3    container  TC;
            2    6     4  accumulator  Ljava/util/function/BiConsumer<TC;Lcom/datastax/oss/driver/api/core/cql/Row;>;
            3    6     5     finisher  Ljava/util/function/Function<TC;TR;>;
    Signature: <C:Ljava/lang/Object;R:Ljava/lang/Object;>(Lcom/datastax/oss/driver/api/core/cql/Statement;Ljava/util/stream/Collector<Lcom/datastax/oss/driver/api/core/cql/Row;TC;TR;>;)Lio/vertx/core/Future<TR;>;
    MethodParameters:
           Name  Flags
      statement  
      collector  

  public io.vertx.cassandra.CassandraClient prepare(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<com.datastax.oss.driver.api.core.cql.PreparedStatement>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // java.lang.String query
        start local 2 // io.vertx.core.Handler resultHandler
         0: .line 176
            aload 0 /* this */
            aload 1 /* query */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.prepare:(Ljava/lang/String;)Lio/vertx/core/Future;
            astore 3 /* future */
        start local 3 // io.vertx.core.Future future
         1: .line 177
            aload 3 /* future */
            aload 2 /* resultHandler */
            invokestatic io.vertx.cassandra.impl.Util.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
         2: .line 178
            aload 0 /* this */
            areturn
        end local 3 // io.vertx.core.Future future
        end local 2 // io.vertx.core.Handler resultHandler
        end local 1 // java.lang.String query
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    3     0           this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1          query  Ljava/lang/String;
            0    3     2  resultHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lcom/datastax/oss/driver/api/core/cql/PreparedStatement;>;>;
            1    3     3         future  Lio/vertx/core/Future<Lcom/datastax/oss/driver/api/core/cql/PreparedStatement;>;
    Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lcom/datastax/oss/driver/api/core/cql/PreparedStatement;>;>;)Lio/vertx/cassandra/CassandraClient;
    MethodParameters:
               Name  Flags
      query          
      resultHandler  

  public io.vertx.core.Future<com.datastax.oss.driver.api.core.cql.PreparedStatement> prepare(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // java.lang.String query
         0: .line 183
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.getSession:(Lio/vertx/core/impl/ContextInternal;)Lio/vertx/core/Future;
         1: .line 184
            aload 0 /* this */
            aload 1 /* query */
            invokedynamic apply(Lio/vertx/cassandra/impl/CassandraClientImpl;Ljava/lang/String;)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/cassandra/impl/CassandraClientImpl.lambda$9(Ljava/lang/String;Lcom/datastax/oss/driver/api/core/CqlSession;)Lio/vertx/core/Future; (7)
                  (Lcom/datastax/oss/driver/api/core/CqlSession;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Future.flatMap:(Ljava/util/function/Function;)Lio/vertx/core/Future;
         2: .line 183
            areturn
        end local 1 // java.lang.String query
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    3     0   this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1  query  Ljava/lang/String;
    Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Lcom/datastax/oss/driver/api/core/cql/PreparedStatement;>;
    MethodParameters:
       Name  Flags
      query  

  public io.vertx.cassandra.CassandraClient prepare(com.datastax.oss.driver.api.core.cql.SimpleStatement, io.vertx.core.Handler<io.vertx.core.AsyncResult<com.datastax.oss.driver.api.core.cql.PreparedStatement>>);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // com.datastax.oss.driver.api.core.cql.SimpleStatement statement
        start local 2 // io.vertx.core.Handler resultHandler
         0: .line 189
            aload 0 /* this */
            aload 1 /* statement */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.prepare:(Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;)Lio/vertx/core/Future;
            astore 3 /* future */
        start local 3 // io.vertx.core.Future future
         1: .line 190
            aload 3 /* future */
            aload 2 /* resultHandler */
            invokestatic io.vertx.cassandra.impl.Util.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
         2: .line 191
            aload 0 /* this */
            areturn
        end local 3 // io.vertx.core.Future future
        end local 2 // io.vertx.core.Handler resultHandler
        end local 1 // com.datastax.oss.driver.api.core.cql.SimpleStatement statement
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    3     0           this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1      statement  Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;
            0    3     2  resultHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lcom/datastax/oss/driver/api/core/cql/PreparedStatement;>;>;
            1    3     3         future  Lio/vertx/core/Future<Lcom/datastax/oss/driver/api/core/cql/PreparedStatement;>;
    Signature: (Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lcom/datastax/oss/driver/api/core/cql/PreparedStatement;>;>;)Lio/vertx/cassandra/CassandraClient;
    MethodParameters:
               Name  Flags
      statement      
      resultHandler  

  public io.vertx.core.Future<com.datastax.oss.driver.api.core.cql.PreparedStatement> prepare(com.datastax.oss.driver.api.core.cql.SimpleStatement);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // com.datastax.oss.driver.api.core.cql.SimpleStatement statement
         0: .line 196
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.getSession:(Lio/vertx/core/impl/ContextInternal;)Lio/vertx/core/Future;
         1: .line 197
            aload 0 /* this */
            aload 1 /* statement */
            invokedynamic apply(Lio/vertx/cassandra/impl/CassandraClientImpl;Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;)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/cassandra/impl/CassandraClientImpl.lambda$10(Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;Lcom/datastax/oss/driver/api/core/CqlSession;)Lio/vertx/core/Future; (7)
                  (Lcom/datastax/oss/driver/api/core/CqlSession;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Future.flatMap:(Ljava/util/function/Function;)Lio/vertx/core/Future;
         2: .line 196
            areturn
        end local 1 // com.datastax.oss.driver.api.core.cql.SimpleStatement statement
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1  statement  Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;
    Signature: (Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;)Lio/vertx/core/Future<Lcom/datastax/oss/driver/api/core/cql/PreparedStatement;>;
    MethodParameters:
           Name  Flags
      statement  

  public io.vertx.cassandra.CassandraClient queryStream(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.cassandra.CassandraRowStream>>);
    descriptor: (Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // java.lang.String sql
        start local 2 // io.vertx.core.Handler rowStreamHandler
         0: .line 202
            aload 0 /* this */
            aload 1 /* sql */
            invokestatic com.datastax.oss.driver.api.core.cql.SimpleStatement.newInstance:(Ljava/lang/String;)Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;
            aload 2 /* rowStreamHandler */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.queryStream:(Lcom/datastax/oss/driver/api/core/cql/Statement;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
            areturn
        end local 2 // io.vertx.core.Handler rowStreamHandler
        end local 1 // java.lang.String sql
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    1     0              this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    1     1               sql  Ljava/lang/String;
            0    1     2  rowStreamHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/CassandraRowStream;>;>;
    Signature: (Ljava/lang/String;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/CassandraRowStream;>;>;)Lio/vertx/cassandra/CassandraClient;
    MethodParameters:
                  Name  Flags
      sql               
      rowStreamHandler  

  public io.vertx.core.Future<io.vertx.cassandra.CassandraRowStream> queryStream(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // java.lang.String sql
         0: .line 207
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 2 /* promise */
        start local 2 // io.vertx.core.Promise promise
         1: .line 208
            aload 0 /* this */
            aload 1 /* sql */
            aload 2 /* promise */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.queryStream:(Ljava/lang/String;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
            pop
         2: .line 209
            aload 2 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.core.Promise promise
        end local 1 // java.lang.String sql
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1      sql  Ljava/lang/String;
            1    3     2  promise  Lio/vertx/core/Promise<Lio/vertx/cassandra/CassandraRowStream;>;
    Signature: (Ljava/lang/String;)Lio/vertx/core/Future<Lio/vertx/cassandra/CassandraRowStream;>;
    MethodParameters:
      Name  Flags
      sql   

  public io.vertx.cassandra.CassandraClient queryStream(com.datastax.oss.driver.api.core.cql.Statement, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.cassandra.CassandraRowStream>>);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/Statement;Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        start local 2 // io.vertx.core.Handler rowStreamHandler
         0: .line 214
            aload 0 /* this */
            aload 1 /* statement */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.queryStream:(Lcom/datastax/oss/driver/api/core/cql/Statement;)Lio/vertx/core/Future;
            astore 3 /* future */
        start local 3 // io.vertx.core.Future future
         1: .line 215
            aload 3 /* future */
            aload 2 /* rowStreamHandler */
            invokestatic io.vertx.cassandra.impl.Util.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
         2: .line 216
            aload 0 /* this */
            areturn
        end local 3 // io.vertx.core.Future future
        end local 2 // io.vertx.core.Handler rowStreamHandler
        end local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    3     0              this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1         statement  Lcom/datastax/oss/driver/api/core/cql/Statement;
            0    3     2  rowStreamHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/CassandraRowStream;>;>;
            1    3     3            future  Lio/vertx/core/Future<Lio/vertx/cassandra/CassandraRowStream;>;
    Signature: (Lcom/datastax/oss/driver/api/core/cql/Statement;Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lio/vertx/cassandra/CassandraRowStream;>;>;)Lio/vertx/cassandra/CassandraClient;
    MethodParameters:
                  Name  Flags
      statement         
      rowStreamHandler  

  public io.vertx.core.Future<io.vertx.cassandra.CassandraRowStream> queryStream(com.datastax.oss.driver.api.core.cql.Statement);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/Statement;)Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
         0: .line 221
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.getSession:(Lio/vertx/core/impl/ContextInternal;)Lio/vertx/core/Future;
         1: .line 222
            aload 0 /* this */
            aload 1 /* statement */
            invokedynamic apply(Lio/vertx/cassandra/impl/CassandraClientImpl;Lcom/datastax/oss/driver/api/core/cql/Statement;)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/cassandra/impl/CassandraClientImpl.lambda$11(Lcom/datastax/oss/driver/api/core/cql/Statement;Lcom/datastax/oss/driver/api/core/CqlSession;)Lio/vertx/core/Future; (7)
                  (Lcom/datastax/oss/driver/api/core/CqlSession;)Lio/vertx/core/Future;
            invokeinterface io.vertx.core.Future.flatMap:(Ljava/util/function/Function;)Lio/vertx/core/Future;
         2: .line 223
            aload 0 /* this */
            invokedynamic apply(Lio/vertx/cassandra/impl/CassandraClientImpl;)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/cassandra/impl/CassandraClientImpl.lambda$12(Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;)Lio/vertx/cassandra/CassandraRowStream; (7)
                  (Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;)Lio/vertx/cassandra/CassandraRowStream;
            invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
         3: .line 221
            areturn
        end local 1 // com.datastax.oss.driver.api.core.cql.Statement statement
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    4     0       this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    4     1  statement  Lcom/datastax/oss/driver/api/core/cql/Statement;
    Signature: (Lcom/datastax/oss/driver/api/core/cql/Statement;)Lio/vertx/core/Future<Lio/vertx/cassandra/CassandraRowStream;>;
    MethodParameters:
           Name  Flags
      statement  

  public io.vertx.core.Future<java.lang.Void> close();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=4, args_size=1
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
         0: .line 231
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            astore 1 /* context */
        start local 1 // io.vertx.core.impl.ContextInternal context
         1: .line 232
            aload 0 /* this */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.raiseCloseFlag:()Z
            ifeq 9
         2: .line 234
      StackMap locals: io.vertx.core.impl.ContextInternal
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.holders:Ljava/util/Map;
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.clientName:Ljava/lang/String;
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.cassandra.impl.SessionHolder
            astore 2 /* current */
        start local 2 // io.vertx.cassandra.impl.SessionHolder current
         3: .line 235
            aload 2 /* current */
            invokevirtual io.vertx.cassandra.impl.SessionHolder.decrement:()Lio/vertx/cassandra/impl/SessionHolder;
            astore 3 /* next */
        start local 3 // io.vertx.cassandra.impl.SessionHolder next
         4: .line 236
            aload 3 /* next */
            getfield io.vertx.cassandra.impl.SessionHolder.refCount:I
            ifne 8
         5: .line 237
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.holders:Ljava/util/Map;
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.clientName:Ljava/lang/String;
            aload 2 /* current */
            invokeinterface java.util.Map.remove:(Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 2
         6: .line 238
            aload 2 /* current */
            getfield io.vertx.cassandra.impl.SessionHolder.session:Lcom/datastax/oss/driver/api/core/CqlSession;
            ifnull 9
         7: .line 239
            aload 2 /* current */
            getfield io.vertx.cassandra.impl.SessionHolder.session:Lcom/datastax/oss/driver/api/core/CqlSession;
            invokeinterface com.datastax.oss.driver.api.core.CqlSession.closeAsync:()Ljava/util/concurrent/CompletionStage;
            aload 1 /* context */
            invokestatic io.vertx.core.Future.fromCompletionStage:(Ljava/util/concurrent/CompletionStage;Lio/vertx/core/Context;)Lio/vertx/core/Future;
            areturn
         8: .line 243
      StackMap locals: io.vertx.cassandra.impl.SessionHolder io.vertx.cassandra.impl.SessionHolder
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.holders:Ljava/util/Map;
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.clientName:Ljava/lang/String;
            aload 2 /* current */
            aload 3 /* next */
            invokeinterface java.util.Map.replace:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Z
            ifeq 2
        end local 3 // io.vertx.cassandra.impl.SessionHolder next
        end local 2 // io.vertx.cassandra.impl.SessionHolder current
         9: .line 248
      StackMap locals:
      StackMap stack:
            aload 1 /* context */
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:()Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.impl.ContextInternal context
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   10     0     this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            1   10     1  context  Lio/vertx/core/impl/ContextInternal;
            3    9     2  current  Lio/vertx/cassandra/impl/SessionHolder;
            4    9     3     next  Lio/vertx/cassandra/impl/SessionHolder;
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  public io.vertx.cassandra.CassandraClient close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraClient;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // io.vertx.core.Handler closeHandler
         0: .line 253
            aload 0 /* this */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.close:()Lio/vertx/core/Future;
            astore 2 /* future */
        start local 2 // io.vertx.core.Future future
         1: .line 254
            aload 2 /* future */
            aload 1 /* closeHandler */
            invokestatic io.vertx.cassandra.impl.Util.setHandler:(Lio/vertx/core/Future;Lio/vertx/core/Handler;)V
         2: .line 255
            aload 0 /* this */
            areturn
        end local 2 // io.vertx.core.Future future
        end local 1 // io.vertx.core.Handler closeHandler
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    3     1  closeHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
            1    3     2        future  Lio/vertx/core/Future<Ljava/lang/Void;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/cassandra/CassandraClient;
    MethodParameters:
              Name  Flags
      closeHandler  

  public io.vertx.core.Future<com.datastax.oss.driver.api.core.metadata.Metadata> metadata();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
         0: .line 260
            aload 0 /* this */
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getOrCreateContext:()Lio/vertx/core/impl/ContextInternal;
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.getSession:(Lio/vertx/core/impl/ContextInternal;)Lio/vertx/core/Future;
            invokedynamic apply()Ljava/util/function/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  com/datastax/oss/driver/api/core/session/Session.getMetadata()Lcom/datastax/oss/driver/api/core/metadata/Metadata; (9 itf)
                  (Lcom/datastax/oss/driver/api/core/CqlSession;)Lcom/datastax/oss/driver/api/core/metadata/Metadata;
            invokeinterface io.vertx.core.Future.map:(Ljava/util/function/Function;)Lio/vertx/core/Future;
            areturn
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/cassandra/impl/CassandraClientImpl;
    Signature: ()Lio/vertx/core/Future<Lcom/datastax/oss/driver/api/core/metadata/Metadata;>;

  public void metadata(io.vertx.core.Handler<io.vertx.core.AsyncResult<com.datastax.oss.driver.api.core.metadata.Metadata>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 265
            aload 0 /* this */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.metadata:()Lio/vertx/core/Future;
            aload 1 /* handler */
            invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         1: .line 266
            return
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    2     1  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lcom/datastax/oss/driver/api/core/metadata/Metadata;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Lcom/datastax/oss/driver/api/core/metadata/Metadata;>;>;)V
    MethodParameters:
         Name  Flags
      handler  

  private synchronized boolean raiseCloseFlag();
    descriptor: ()Z
    flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
         0: .line 269
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.closed:Z
            ifne 3
         1: .line 270
            aload 0 /* this */
            iconst_1
            putfield io.vertx.cassandra.impl.CassandraClientImpl.closed:Z
         2: .line 271
            iconst_1
            ireturn
         3: .line 273
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/vertx/cassandra/impl/CassandraClientImpl;

  synchronized io.vertx.core.Future<com.datastax.oss.driver.api.core.CqlSession> getSession(io.vertx.core.impl.ContextInternal);
    descriptor: (Lio/vertx/core/impl/ContextInternal;)Lio/vertx/core/Future;
    flags: (0x0020) ACC_SYNCHRONIZED
    Code:
      stack=3, locals=3, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // io.vertx.core.impl.ContextInternal context
         0: .line 277
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.closed:Z
            ifeq 2
         1: .line 278
            aload 1 /* context */
            ldc "Client is closed"
            invokeinterface io.vertx.core.impl.ContextInternal.failedFuture:(Ljava/lang/String;)Lio/vertx/core/Future;
            areturn
         2: .line 280
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.holders:Ljava/util/Map;
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.clientName:Ljava/lang/String;
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.cassandra.impl.SessionHolder
            astore 2 /* holder */
        start local 2 // io.vertx.cassandra.impl.SessionHolder holder
         3: .line 281
            aload 2 /* holder */
            getfield io.vertx.cassandra.impl.SessionHolder.session:Lcom/datastax/oss/driver/api/core/CqlSession;
            ifnull 5
         4: .line 282
            aload 1 /* context */
            aload 2 /* holder */
            getfield io.vertx.cassandra.impl.SessionHolder.session:Lcom/datastax/oss/driver/api/core/CqlSession;
            invokeinterface io.vertx.core.impl.ContextInternal.succeededFuture:(Ljava/lang/Object;)Lio/vertx/core/Future;
            areturn
         5: .line 284
      StackMap locals: io.vertx.cassandra.impl.SessionHolder
      StackMap stack:
            aload 1 /* context */
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/cassandra/impl/CassandraClientImpl;)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/cassandra/impl/CassandraClientImpl.lambda$14(Lio/vertx/core/Promise;)V (7)
                  (Lio/vertx/core/Promise;)V
         6: .line 286
            aload 2 /* holder */
            getfield io.vertx.cassandra.impl.SessionHolder.connectionQueue:Lio/vertx/core/impl/TaskQueue;
         7: .line 284
            invokeinterface io.vertx.core.impl.ContextInternal.executeBlocking:(Lio/vertx/core/Handler;Lio/vertx/core/impl/TaskQueue;)Lio/vertx/core/Future;
            areturn
        end local 2 // io.vertx.cassandra.impl.SessionHolder holder
        end local 1 // io.vertx.core.impl.ContextInternal context
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    8     0     this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    8     1  context  Lio/vertx/core/impl/ContextInternal;
            3    8     2   holder  Lio/vertx/cassandra/impl/SessionHolder;
    Signature: (Lio/vertx/core/impl/ContextInternal;)Lio/vertx/core/Future<Lcom/datastax/oss/driver/api/core/CqlSession;>;
    MethodParameters:
         Name  Flags
      context  

  private void connect(io.vertx.core.Promise<com.datastax.oss.driver.api.core.CqlSession>);
    descriptor: (Lio/vertx/core/Promise;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=5, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // io.vertx.core.Promise promise
         0: .line 290
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.holders:Ljava/util/Map;
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.clientName:Ljava/lang/String;
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.cassandra.impl.SessionHolder
            astore 2 /* current */
        start local 2 // io.vertx.cassandra.impl.SessionHolder current
         1: .line 291
            aload 2 /* current */
            ifnonnull 4
         2: .line 292
            aload 1 /* promise */
            ldc "Client closed while connecting"
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/String;)V
         3: .line 293
            return
         4: .line 295
      StackMap locals: io.vertx.cassandra.impl.SessionHolder
      StackMap stack:
            aload 2 /* current */
            getfield io.vertx.cassandra.impl.SessionHolder.session:Lcom/datastax/oss/driver/api/core/CqlSession;
            ifnull 7
         5: .line 296
            aload 1 /* promise */
            aload 2 /* current */
            getfield io.vertx.cassandra.impl.SessionHolder.session:Lcom/datastax/oss/driver/api/core/CqlSession;
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
         6: .line 297
            return
         7: .line 299
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.options:Lio/vertx/cassandra/CassandraClientOptions;
            invokevirtual io.vertx.cassandra.CassandraClientOptions.dataStaxClusterBuilder:()Lcom/datastax/oss/driver/api/core/CqlSessionBuilder;
            astore 3 /* builder */
        start local 3 // com.datastax.oss.driver.api.core.CqlSessionBuilder builder
         8: .line 300
            aload 3 /* builder */
            invokevirtual com.datastax.oss.driver.api.core.CqlSessionBuilder.build:()Ljava/lang/Object;
            checkcast com.datastax.oss.driver.api.core.CqlSession
            astore 4 /* session */
        start local 4 // com.datastax.oss.driver.api.core.CqlSession session
         9: .line 301
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.holders:Ljava/util/Map;
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.clientName:Ljava/lang/String;
            aload 4 /* session */
            invokedynamic apply(Lcom/datastax/oss/driver/api/core/CqlSession;)Ljava/util/function/BiFunction;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
                  io/vertx/cassandra/impl/CassandraClientImpl.lambda$15(Lcom/datastax/oss/driver/api/core/CqlSession;Ljava/lang/String;Lio/vertx/cassandra/impl/SessionHolder;)Lio/vertx/cassandra/impl/SessionHolder; (6)
                  (Ljava/lang/String;Lio/vertx/cassandra/impl/SessionHolder;)Lio/vertx/cassandra/impl/SessionHolder;
            invokeinterface java.util.Map.compute:(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object;
            checkcast io.vertx.cassandra.impl.SessionHolder
            astore 2 /* current */
        10: .line 302
            aload 2 /* current */
            ifnull 13
        11: .line 303
            aload 1 /* promise */
            aload 2 /* current */
            getfield io.vertx.cassandra.impl.SessionHolder.session:Lcom/datastax/oss/driver/api/core/CqlSession;
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        12: .line 304
            goto 17
        13: .line 306
      StackMap locals: com.datastax.oss.driver.api.core.CqlSessionBuilder com.datastax.oss.driver.api.core.CqlSession
      StackMap stack:
            aload 4 /* session */
            invokeinterface com.datastax.oss.driver.api.core.CqlSession.close:()V
        14: .line 307
            goto 16
      StackMap locals:
      StackMap stack: java.lang.Exception
        15: pop
        16: .line 309
      StackMap locals:
      StackMap stack:
            aload 1 /* promise */
            ldc "Client closed while connecting"
            invokeinterface io.vertx.core.Promise.fail:(Ljava/lang/String;)V
        17: .line 311
      StackMap locals:
      StackMap stack:
            return
        end local 4 // com.datastax.oss.driver.api.core.CqlSession session
        end local 3 // com.datastax.oss.driver.api.core.CqlSessionBuilder builder
        end local 2 // io.vertx.cassandra.impl.SessionHolder current
        end local 1 // io.vertx.core.Promise promise
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   18     0     this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0   18     1  promise  Lio/vertx/core/Promise<Lcom/datastax/oss/driver/api/core/CqlSession;>;
            1   18     2  current  Lio/vertx/cassandra/impl/SessionHolder;
            8   18     3  builder  Lcom/datastax/oss/driver/api/core/CqlSessionBuilder;
            9   18     4  session  Lcom/datastax/oss/driver/api/core/CqlSession;
      Exception table:
        from    to  target  type
          13    14      15  Class java.lang.Exception
    Signature: (Lio/vertx/core/Promise<Lcom/datastax/oss/driver/api/core/CqlSession;>;)V
    MethodParameters:
         Name  Flags
      promise  

  private static io.vertx.cassandra.impl.SessionHolder lambda$0(java.lang.String, io.vertx.cassandra.impl.SessionHolder);
    descriptor: (Ljava/lang/String;Lio/vertx/cassandra/impl/SessionHolder;)Lio/vertx/cassandra/impl/SessionHolder;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // java.lang.String k
        start local 1 // io.vertx.cassandra.impl.SessionHolder h
         0: .line 68
            aload 1 /* h */
            ifnonnull 1
            new io.vertx.cassandra.impl.SessionHolder
            dup
            invokespecial io.vertx.cassandra.impl.SessionHolder.<init>:()V
            goto 2
      StackMap locals:
      StackMap stack:
         1: aload 1 /* h */
            invokevirtual io.vertx.cassandra.impl.SessionHolder.increment:()Lio/vertx/cassandra/impl/SessionHolder;
      StackMap locals:
      StackMap stack: io.vertx.cassandra.impl.SessionHolder
         2: areturn
        end local 1 // io.vertx.cassandra.impl.SessionHolder h
        end local 0 // java.lang.String k
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0     k  Ljava/lang/String;
            0    3     1     h  Lio/vertx/cassandra/impl/SessionHolder;

  private io.vertx.core.Future lambda$3(com.datastax.oss.driver.api.core.cql.Statement, com.datastax.oss.driver.api.core.CqlSession);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/Statement;Lcom/datastax/oss/driver/api/core/CqlSession;)Lio/vertx/core/Future;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 2 // com.datastax.oss.driver.api.core.CqlSession session
         0: .line 139
            aload 2 /* session */
            aload 1
            invokeinterface com.datastax.oss.driver.api.core.CqlSession.executeAsync:(Lcom/datastax/oss/driver/api/core/cql/Statement;)Ljava/util/concurrent/CompletionStage;
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getContext:()Lio/vertx/core/impl/ContextInternal;
            invokestatic io.vertx.core.Future.fromCompletionStage:(Ljava/util/concurrent/CompletionStage;Lio/vertx/core/Context;)Lio/vertx/core/Future;
            areturn
        end local 2 // com.datastax.oss.driver.api.core.CqlSession session
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    1     2  session  Lcom/datastax/oss/driver/api/core/CqlSession;

  private io.vertx.cassandra.ResultSet lambda$4(com.datastax.oss.driver.api.core.cql.AsyncResultSet);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;)Lio/vertx/cassandra/ResultSet;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // com.datastax.oss.driver.api.core.cql.AsyncResultSet rs
         0: .line 140
            new io.vertx.cassandra.impl.ResultSetImpl
            dup
            aload 1 /* rs */
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokespecial io.vertx.cassandra.impl.ResultSetImpl.<init>:(Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;Lio/vertx/core/Vertx;)V
            areturn
        end local 1 // com.datastax.oss.driver.api.core.cql.AsyncResultSet rs
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    1     1    rs  Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;

  private static io.vertx.core.Future lambda$5(java.util.function.Function, java.lang.Object, java.util.function.BiConsumer, io.vertx.cassandra.CassandraRowStream);
    descriptor: (Ljava/util/function/Function;Ljava/lang/Object;Ljava/util/function/BiConsumer;Lio/vertx/cassandra/CassandraRowStream;)Lio/vertx/core/Future;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=4, locals=5, args_size=4
        start local 3 // io.vertx.cassandra.CassandraRowStream cassandraRowStream
         0: .line 161
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 4 /* resultPromise */
        start local 4 // io.vertx.core.Promise resultPromise
         1: .line 162
            aload 3 /* cassandraRowStream */
            aload 0
            aload 1
            aload 4 /* resultPromise */
            invokedynamic handle(Ljava/util/function/Function;Ljava/lang/Object;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/cassandra/impl/CassandraClientImpl.lambda$6(Ljava/util/function/Function;Ljava/lang/Object;Lio/vertx/core/Promise;Ljava/lang/Void;)V (6)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.cassandra.CassandraRowStream.endHandler:(Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraRowStream;
            pop
         2: .line 166
            aload 3 /* cassandraRowStream */
            aload 2
            aload 1
            invokedynamic handle(Ljava/util/function/BiConsumer;Ljava/lang/Object;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/cassandra/impl/CassandraClientImpl.lambda$7(Ljava/util/function/BiConsumer;Ljava/lang/Object;Lcom/datastax/oss/driver/api/core/cql/Row;)V (6)
                  (Lcom/datastax/oss/driver/api/core/cql/Row;)V
            invokeinterface io.vertx.cassandra.CassandraRowStream.handler:(Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraRowStream;
            pop
         3: .line 169
            aload 3 /* cassandraRowStream */
            aload 4 /* resultPromise */
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            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/core/Promise.fail(Ljava/lang/Throwable;)V (9 itf)
                  (Ljava/lang/Throwable;)V
            invokeinterface io.vertx.cassandra.CassandraRowStream.exceptionHandler:(Lio/vertx/core/Handler;)Lio/vertx/cassandra/CassandraRowStream;
            pop
         4: .line 170
            aload 4 /* resultPromise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 4 // io.vertx.core.Promise resultPromise
        end local 3 // io.vertx.cassandra.CassandraRowStream cassandraRowStream
      LocalVariableTable:
        Start  End  Slot                Name  Signature
            0    5     3  cassandraRowStream  Lio/vertx/cassandra/CassandraRowStream;
            1    5     4       resultPromise  Lio/vertx/core/Promise<TR;>;

  private io.vertx.core.Future lambda$9(java.lang.String, com.datastax.oss.driver.api.core.CqlSession);
    descriptor: (Ljava/lang/String;Lcom/datastax/oss/driver/api/core/CqlSession;)Lio/vertx/core/Future;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 2 // com.datastax.oss.driver.api.core.CqlSession session
         0: .line 184
            aload 2 /* session */
            aload 1
            invokeinterface com.datastax.oss.driver.api.core.CqlSession.prepareAsync:(Ljava/lang/String;)Ljava/util/concurrent/CompletionStage;
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getContext:()Lio/vertx/core/impl/ContextInternal;
            invokestatic io.vertx.core.Future.fromCompletionStage:(Ljava/util/concurrent/CompletionStage;Lio/vertx/core/Context;)Lio/vertx/core/Future;
            areturn
        end local 2 // com.datastax.oss.driver.api.core.CqlSession session
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    1     2  session  Lcom/datastax/oss/driver/api/core/CqlSession;

  private io.vertx.core.Future lambda$10(com.datastax.oss.driver.api.core.cql.SimpleStatement, com.datastax.oss.driver.api.core.CqlSession);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;Lcom/datastax/oss/driver/api/core/CqlSession;)Lio/vertx/core/Future;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 2 // com.datastax.oss.driver.api.core.CqlSession session
         0: .line 197
            aload 2 /* session */
            aload 1
            invokeinterface com.datastax.oss.driver.api.core.CqlSession.prepareAsync:(Lcom/datastax/oss/driver/api/core/cql/SimpleStatement;)Ljava/util/concurrent/CompletionStage;
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getContext:()Lio/vertx/core/impl/ContextInternal;
            invokestatic io.vertx.core.Future.fromCompletionStage:(Ljava/util/concurrent/CompletionStage;Lio/vertx/core/Context;)Lio/vertx/core/Future;
            areturn
        end local 2 // com.datastax.oss.driver.api.core.CqlSession session
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    1     2  session  Lcom/datastax/oss/driver/api/core/CqlSession;

  private io.vertx.core.Future lambda$11(com.datastax.oss.driver.api.core.cql.Statement, com.datastax.oss.driver.api.core.CqlSession);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/Statement;Lcom/datastax/oss/driver/api/core/CqlSession;)Lio/vertx/core/Future;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 2 // com.datastax.oss.driver.api.core.CqlSession session
         0: .line 222
            aload 2 /* session */
            aload 1
            invokeinterface com.datastax.oss.driver.api.core.CqlSession.executeAsync:(Lcom/datastax/oss/driver/api/core/cql/Statement;)Ljava/util/concurrent/CompletionStage;
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getContext:()Lio/vertx/core/impl/ContextInternal;
            invokestatic io.vertx.core.Future.fromCompletionStage:(Ljava/util/concurrent/CompletionStage;Lio/vertx/core/Context;)Lio/vertx/core/Future;
            areturn
        end local 2 // com.datastax.oss.driver.api.core.CqlSession session
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    1     2  session  Lcom/datastax/oss/driver/api/core/CqlSession;

  private io.vertx.cassandra.CassandraRowStream lambda$12(com.datastax.oss.driver.api.core.cql.AsyncResultSet);
    descriptor: (Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;)Lio/vertx/cassandra/CassandraRowStream;
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // com.datastax.oss.driver.api.core.cql.AsyncResultSet rs
         0: .line 224
            new io.vertx.cassandra.impl.ResultSetImpl
            dup
            aload 1 /* rs */
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokespecial io.vertx.cassandra.impl.ResultSetImpl.<init>:(Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;Lio/vertx/core/Vertx;)V
            astore 2 /* resultSet */
        start local 2 // io.vertx.cassandra.ResultSet resultSet
         1: .line 225
            new io.vertx.cassandra.impl.CassandraRowStreamImpl
            dup
            aload 0 /* this */
            getfield io.vertx.cassandra.impl.CassandraClientImpl.vertx:Lio/vertx/core/impl/VertxInternal;
            invokeinterface io.vertx.core.impl.VertxInternal.getContext:()Lio/vertx/core/impl/ContextInternal;
            aload 2 /* resultSet */
            invokespecial io.vertx.cassandra.impl.CassandraRowStreamImpl.<init>:(Lio/vertx/core/Context;Lio/vertx/cassandra/ResultSet;)V
            areturn
        end local 2 // io.vertx.cassandra.ResultSet resultSet
        end local 1 // com.datastax.oss.driver.api.core.cql.AsyncResultSet rs
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    2     1         rs  Lcom/datastax/oss/driver/api/core/cql/AsyncResultSet;
            1    2     2  resultSet  Lio/vertx/cassandra/ResultSet;

  private void lambda$14(io.vertx.core.Promise);
    descriptor: (Lio/vertx/core/Promise;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
        start local 1 // io.vertx.core.Promise promise
         0: .line 285
            aload 0 /* this */
            aload 1 /* promise */
            invokevirtual io.vertx.cassandra.impl.CassandraClientImpl.connect:(Lio/vertx/core/Promise;)V
         1: .line 286
            return
        end local 1 // io.vertx.core.Promise promise
        end local 0 // io.vertx.cassandra.impl.CassandraClientImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/cassandra/impl/CassandraClientImpl;
            0    2     1  promise  Lio/vertx/core/Promise<Lcom/datastax/oss/driver/api/core/CqlSession;>;

  private static io.vertx.cassandra.impl.SessionHolder lambda$15(com.datastax.oss.driver.api.core.CqlSession, java.lang.String, io.vertx.cassandra.impl.SessionHolder);
    descriptor: (Lcom/datastax/oss/driver/api/core/CqlSession;Ljava/lang/String;Lio/vertx/cassandra/impl/SessionHolder;)Lio/vertx/cassandra/impl/SessionHolder;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 1 // java.lang.String k
        start local 2 // io.vertx.cassandra.impl.SessionHolder h
         0: .line 301
            aload 2 /* h */
            ifnonnull 1
            aconst_null
            goto 2
      StackMap locals:
      StackMap stack:
         1: aload 2 /* h */
            aload 0
            invokevirtual io.vertx.cassandra.impl.SessionHolder.connected:(Lcom/datastax/oss/driver/api/core/CqlSession;)Lio/vertx/cassandra/impl/SessionHolder;
      StackMap locals:
      StackMap stack: io.vertx.cassandra.impl.SessionHolder
         2: areturn
        end local 2 // io.vertx.cassandra.impl.SessionHolder h
        end local 1 // java.lang.String k
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     1     k  Ljava/lang/String;
            0    3     2     h  Lio/vertx/cassandra/impl/SessionHolder;

  private static void lambda$6(java.util.function.Function, java.lang.Object, io.vertx.core.Promise, java.lang.Void);
    descriptor: (Ljava/util/function/Function;Ljava/lang/Object;Lio/vertx/core/Promise;Ljava/lang/Void;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=5, args_size=4
        start local 3 // java.lang.Void end
         0: .line 163
            aload 0
            aload 1
            invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
            astore 4 /* result */
        start local 4 // java.lang.Object result
         1: .line 164
            aload 2
            aload 4 /* result */
            invokeinterface io.vertx.core.Promise.complete:(Ljava/lang/Object;)V
        end local 4 // java.lang.Object result
         2: .line 165
            return
        end local 3 // java.lang.Void end
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    3     3     end  Ljava/lang/Void;
            1    2     4  result  TR;

  private static void lambda$7(java.util.function.BiConsumer, java.lang.Object, com.datastax.oss.driver.api.core.cql.Row);
    descriptor: (Ljava/util/function/BiConsumer;Ljava/lang/Object;Lcom/datastax/oss/driver/api/core/cql/Row;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 2 // com.datastax.oss.driver.api.core.cql.Row row
         0: .line 167
            aload 0
            aload 1
            aload 2 /* row */
            invokeinterface java.util.function.BiConsumer.accept:(Ljava/lang/Object;Ljava/lang/Object;)V
         1: .line 168
            return
        end local 2 // com.datastax.oss.driver.api.core.cql.Row row
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     2   row  Lcom/datastax/oss/driver/api/core/cql/Row;
}
SourceFile: "CassandraClientImpl.java"
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles