public class io.vertx.pgclient.impl.pubsub.PgSubscriberImpl implements io.vertx.pgclient.pubsub.PgSubscriber
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.vertx.pgclient.impl.pubsub.PgSubscriberImpl
  super_class: java.lang.Object
{
  private static io.vertx.core.impl.logging.Logger log;
    descriptor: Lio/vertx/core/impl/logging/Logger;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC

  private static final java.util.function.Function<java.lang.Integer, java.lang.Long> DEFAULT_RECONNECT_POLICY;
    descriptor: Ljava/util/function/Function;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/function/Function<Ljava/lang/Integer;Ljava/lang/Long;>;

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

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

  private java.util.Map<java.lang.String, io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList> channels;
    descriptor: Ljava/util/Map;
    flags: (0x0002) ACC_PRIVATE
    Signature: Ljava/util/Map<Ljava/lang/String;Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;>;

  private java.util.function.Function<java.lang.Integer, java.lang.Long> reconnectPolicy;
    descriptor: Ljava/util/function/Function;
    flags: (0x0002) ACC_PRIVATE
    Signature: Ljava/util/function/Function<Ljava/lang/Integer;Ljava/lang/Long;>;

  private io.vertx.pgclient.PgConnection conn;
    descriptor: Lio/vertx/pgclient/PgConnection;
    flags: (0x0002) ACC_PRIVATE

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

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

  private io.vertx.core.Handler<java.lang.Void> closeHandler;
    descriptor: Lio/vertx/core/Handler;
    flags: (0x0002) ACC_PRIVATE
    Signature: Lio/vertx/core/Handler<Ljava/lang/Void;>;

  public static final int NAMEDATALEN;
    descriptor: I
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: 64

  public static final int MAX_CHANNEL_NAME_LENGTH;
    descriptor: I
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: 63

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 33
            ldc Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            invokestatic io.vertx.core.impl.logging.LoggerFactory.getLogger:(Ljava/lang/Class;)Lio/vertx/core/impl/logging/Logger;
            putstatic io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.log:Lio/vertx/core/impl/logging/Logger;
         1: .line 34
            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/pgclient/impl/pubsub/PgSubscriberImpl.lambda$0(Ljava/lang/Integer;)Ljava/lang/Long; (6)
                  (Ljava/lang/Integer;)Ljava/lang/Long;
            putstatic io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.DEFAULT_RECONNECT_POLICY:Ljava/util/function/Function;
         2: .line 54
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(io.vertx.core.Vertx, io.vertx.pgclient.PgConnectOptions);
    descriptor: (Lio/vertx/core/Vertx;Lio/vertx/pgclient/PgConnectOptions;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=3, args_size=3
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 1 // io.vertx.core.Vertx vertx
        start local 2 // io.vertx.pgclient.PgConnectOptions options
         0: .line 46
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 38
            aload 0 /* this */
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.channels:Ljava/util/Map;
         2: .line 39
            aload 0 /* this */
            getstatic io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.DEFAULT_RECONNECT_POLICY:Ljava/util/function/Function;
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.reconnectPolicy:Ljava/util/function/Function;
         3: .line 43
            aload 0 /* this */
            iconst_1
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.closed:Z
         4: .line 47
            aload 0 /* this */
            aload 1 /* vertx */
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.vertx:Lio/vertx/core/Vertx;
         5: .line 48
            aload 0 /* this */
            new io.vertx.pgclient.PgConnectOptions
            dup
            aload 2 /* options */
            invokespecial io.vertx.pgclient.PgConnectOptions.<init>:(Lio/vertx/pgclient/PgConnectOptions;)V
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.options:Lio/vertx/pgclient/PgConnectOptions;
         6: .line 49
            return
        end local 2 // io.vertx.pgclient.PgConnectOptions options
        end local 1 // io.vertx.core.Vertx vertx
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    7     0     this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0    7     1    vertx  Lio/vertx/core/Vertx;
            0    7     2  options  Lio/vertx/pgclient/PgConnectOptions;
    MethodParameters:
         Name  Flags
      vertx    
      options  

  public static java.lang.String applyIdLengthLimit(java.lang.String);
    descriptor: (Ljava/lang/String;)Ljava/lang/String;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // java.lang.String channelName
         0: .line 56
            aload 0 /* channelName */
            invokevirtual java.lang.String.length:()I
            bipush 63
            if_icmple 2
         1: .line 57
            aload 0 /* channelName */
            iconst_0
            bipush 63
            invokevirtual java.lang.String.substring:(II)Ljava/lang/String;
            goto 3
      StackMap locals:
      StackMap stack:
         2: aload 0 /* channelName */
         3: .line 56
      StackMap locals:
      StackMap stack: java.lang.String
            areturn
        end local 0 // java.lang.String channelName
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    4     0  channelName  Ljava/lang/String;
    MethodParameters:
             Name  Flags
      channelName  

  private void handleNotification(io.vertx.pgclient.PgNotification);
    descriptor: (Lio/vertx/pgclient/PgNotification;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=5, args_size=2
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 1 // io.vertx.pgclient.PgNotification notif
         0: .line 61
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 2 /* handlers */
        start local 2 // java.util.List handlers
         1: .line 62
            aload 0 /* this */
            dup
            astore 3
            monitorenter
         2: .line 63
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.channels:Ljava/util/Map;
            aload 1 /* notif */
            invokevirtual io.vertx.pgclient.PgNotification.getChannel:()Ljava/lang/String;
            invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList
            astore 4 /* channel */
        start local 4 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList channel
         3: .line 64
            aload 4 /* channel */
            ifnull 5
         4: .line 65
            aload 4 /* channel */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList.subs:Ljava/util/ArrayList;
            aload 2 /* handlers */
            invokedynamic accept(Ljava/util/List;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/pgclient/impl/pubsub/PgSubscriberImpl.lambda$1(Ljava/util/List;Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelImpl;)V (6)
                  (Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelImpl;)V
            invokevirtual java.util.ArrayList.forEach:(Ljava/util/function/Consumer;)V
        end local 4 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList channel
         5: .line 62
      StackMap locals: java.util.List io.vertx.pgclient.impl.pubsub.PgSubscriberImpl
      StackMap stack:
            aload 3
            monitorexit
         6: goto 9
      StackMap locals:
      StackMap stack: java.lang.Throwable
         7: aload 3
            monitorexit
         8: athrow
         9: .line 79
      StackMap locals:
      StackMap stack:
            aload 2 /* handlers */
            aload 1 /* notif */
            invokedynamic accept(Lio/vertx/pgclient/PgNotification;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/pgclient/impl/pubsub/PgSubscriberImpl.lambda$2(Lio/vertx/pgclient/PgNotification;Lio/vertx/core/Handler;)V (6)
                  (Lio/vertx/core/Handler;)V
            invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
        10: .line 82
            return
        end local 2 // java.util.List handlers
        end local 1 // io.vertx.pgclient.PgNotification notif
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   11     0      this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0   11     1     notif  Lio/vertx/pgclient/PgNotification;
            1   11     2  handlers  Ljava/util/List<Lio/vertx/core/Handler<Ljava/lang/String;>;>;
            3    5     4   channel  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;
      Exception table:
        from    to  target  type
           2     6       7  any
           7     8       7  any
    MethodParameters:
       Name  Flags
      notif  

  public synchronized io.vertx.pgclient.pubsub.PgSubscriber closeHandler(io.vertx.core.Handler<java.lang.Void>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/pgclient/pubsub/PgSubscriber;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 86
            aload 0 /* this */
            aload 1 /* handler */
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.closeHandler:Lio/vertx/core/Handler;
         1: .line 87
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0    2     1  handler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
    Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/vertx/pgclient/pubsub/PgSubscriber;
    MethodParameters:
         Name  Flags
      handler  

  public synchronized io.vertx.pgclient.pubsub.PgSubscriber reconnectPolicy(java.util.function.Function<java.lang.Integer, java.lang.Long>);
    descriptor: (Ljava/util/function/Function;)Lio/vertx/pgclient/pubsub/PgSubscriber;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 1 // java.util.function.Function policy
         0: .line 92
            aload 1 /* policy */
            ifnonnull 3
         1: .line 93
            aload 0 /* this */
            getstatic io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.DEFAULT_RECONNECT_POLICY:Ljava/util/function/Function;
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.reconnectPolicy:Ljava/util/function/Function;
         2: .line 94
            goto 4
         3: .line 95
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* policy */
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.reconnectPolicy:Ljava/util/function/Function;
         4: .line 97
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 1 // java.util.function.Function policy
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    5     0    this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0    5     1  policy  Ljava/util/function/Function<Ljava/lang/Integer;Ljava/lang/Long;>;
    Signature: (Ljava/util/function/Function<Ljava/lang/Integer;Ljava/lang/Long;>;)Lio/vertx/pgclient/pubsub/PgSubscriber;
    MethodParameters:
        Name  Flags
      policy  

  private synchronized void handleClose(java.lang.Void);
    descriptor: (Ljava/lang/Void;)V
    flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 1 // java.lang.Void v
         0: .line 101
            aload 0 /* this */
            aconst_null
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.conn:Lio/vertx/pgclient/PgConnection;
         1: .line 102
            aload 0 /* this */
            iconst_0
            invokevirtual io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.checkReconnect:(I)V
         2: .line 103
            return
        end local 1 // java.lang.Void v
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0    3     1     v  Ljava/lang/Void;
    MethodParameters:
      Name  Flags
      v     

  private void checkReconnect(int);
    descriptor: (I)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=4, args_size=2
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 1 // int count
         0: .line 106
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.closed:Z
            ifne 6
         1: .line 107
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.reconnectPolicy:Ljava/util/function/Function;
            iload 1 /* count */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast java.lang.Long
            astore 2 /* val */
        start local 2 // java.lang.Long val
         2: .line 108
            aload 2 /* val */
            invokevirtual java.lang.Long.longValue:()J
            lconst_0
            lcmp
            iflt 5
         3: .line 109
            aload 0 /* this */
            aload 2 /* val */
            invokevirtual java.lang.Long.longValue:()J
            aload 0 /* this */
            iload 1 /* count */
            invokedynamic handle(Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;I)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/pgclient/impl/pubsub/PgSubscriberImpl.lambda$3(ILio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokevirtual io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.tryConnect:(JLio/vertx/core/Handler;)V
         4: .line 114
            return
         5: .line 116
      StackMap locals: java.lang.Long
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.closed:Z
        end local 2 // java.lang.Long val
         6: .line 118
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.channels:Ljava/util/Map;
         7: .line 119
            invokeinterface java.util.Map.values:()Ljava/util/Collection;
         8: .line 120
            invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
         9: .line 121
            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/pgclient/impl/pubsub/PgSubscriberImpl.lambda$4(Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;)Ljava/util/stream/Stream; (6)
                  (Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;)Ljava/util/stream/Stream;
            invokeinterface java.util.stream.Stream.flatMap:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
        10: .line 122
            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/pgclient/impl/pubsub/PgSubscriberImpl.lambda$5(Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelImpl;)Lio/vertx/core/Handler; (6)
                  (Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelImpl;)Lio/vertx/core/Handler;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
        11: .line 123
            invokedynamic test()Ljava/util/function/Predicate;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Z
                  java/util/Objects.nonNull(Ljava/lang/Object;)Z (6)
                  (Lio/vertx/core/Handler;)Z
            invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
        12: .line 124
            invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
            invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
            checkcast java.util.List
        13: .line 118
            astore 2 /* all */
        start local 2 // java.util.List all
        14: .line 125
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.channels:Ljava/util/Map;
            invokeinterface java.util.Map.clear:()V
        15: .line 126
            aload 2 /* all */
            invokedynamic accept()Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/pgclient/impl/pubsub/PgSubscriberImpl.lambda$7(Lio/vertx/core/Handler;)V (6)
                  (Lio/vertx/core/Handler;)V
            invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
        16: .line 127
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.closeHandler:Lio/vertx/core/Handler;
            astore 3 /* handler */
        start local 3 // io.vertx.core.Handler handler
        17: .line 128
            aload 3 /* handler */
            ifnull 19
        18: .line 129
            aload 3 /* handler */
            aconst_null
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        19: .line 131
      StackMap locals: java.util.List io.vertx.core.Handler
      StackMap stack:
            return
        end local 3 // io.vertx.core.Handler handler
        end local 2 // java.util.List all
        end local 1 // int count
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0   20     0     this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0   20     1    count  I
            2    6     2      val  Ljava/lang/Long;
           14   20     2      all  Ljava/util/List<Lio/vertx/core/Handler<Ljava/lang/Void;>;>;
           17   20     3  handler  Lio/vertx/core/Handler<Ljava/lang/Void;>;
    MethodParameters:
       Name  Flags
      count  

  public synchronized boolean closed();
    descriptor: ()Z
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
         0: .line 135
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.closed:Z
            ireturn
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;

  public synchronized io.vertx.pgclient.PgConnection actualConnection();
    descriptor: ()Lio/vertx/pgclient/PgConnection;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
         0: .line 140
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.conn:Lio/vertx/pgclient/PgConnection;
            areturn
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;

  public synchronized io.vertx.pgclient.pubsub.PgSubscriber connect(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)Lio/vertx/pgclient/pubsub/PgSubscriber;
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 145
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.closed:Z
            ifeq 3
         1: .line 146
            aload 0 /* this */
            iconst_0
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.closed:Z
         2: .line 147
            aload 0 /* this */
            lconst_0
            aload 1 /* handler */
            invokevirtual io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.tryConnect:(JLio/vertx/core/Handler;)V
         3: .line 149
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0     this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0    4     1  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/vertx/pgclient/pubsub/PgSubscriber;
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.core.Future<java.lang.Void> connect();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
         0: .line 154
            invokestatic io.vertx.core.Promise.promise:()Lio/vertx/core/Promise;
            astore 1 /* promise */
        start local 1 // io.vertx.core.Promise promise
         1: .line 155
            aload 0 /* this */
            aload 1 /* promise */
            invokevirtual io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.connect:(Lio/vertx/core/Handler;)Lio/vertx/pgclient/pubsub/PgSubscriber;
            pop
         2: .line 156
            aload 1 /* promise */
            invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
            areturn
        end local 1 // io.vertx.core.Promise promise
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    3     0     this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            1    3     1  promise  Lio/vertx/core/Promise<Ljava/lang/Void;>;
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  private void tryConnect(long, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (JLio/vertx/core/Handler;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=5, locals=4, args_size=3
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 1 // long delayMillis
        start local 3 // io.vertx.core.Handler handler
         0: .line 160
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.connecting:Z
            ifne 6
         1: .line 161
            aload 0 /* this */
            iconst_1
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.connecting:Z
         2: .line 162
            lload 1 /* delayMillis */
            lconst_0
            lcmp
            ifle 5
         3: .line 163
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.vertx:Lio/vertx/core/Vertx;
            lload 1 /* delayMillis */
            aload 0 /* this */
            aload 3 /* handler */
            invokedynamic handle(Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/pgclient/impl/pubsub/PgSubscriberImpl.lambda$8(Lio/vertx/core/Handler;Ljava/lang/Long;)V (7)
                  (Ljava/lang/Long;)V
            invokeinterface io.vertx.core.Vertx.setTimer:(JLio/vertx/core/Handler;)J
            pop2
         4: .line 164
            goto 6
         5: .line 165
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 3 /* handler */
            invokevirtual io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.doConnect:(Lio/vertx/core/Handler;)V
         6: .line 168
      StackMap locals:
      StackMap stack:
            return
        end local 3 // io.vertx.core.Handler handler
        end local 1 // long delayMillis
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    7     0         this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0    7     1  delayMillis  J
            0    7     3      handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (JLio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
             Name  Flags
      delayMillis  
      handler      

  private void doConnect(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 1 // io.vertx.core.Handler completionHandler
         0: .line 171
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.vertx:Lio/vertx/core/Vertx;
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.options:Lio/vertx/pgclient/PgConnectOptions;
            aload 0 /* this */
            aload 1 /* completionHandler */
            invokedynamic handle(Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/pgclient/impl/pubsub/PgSubscriberImpl.lambda$9(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokestatic io.vertx.pgclient.PgConnection.connect:(Lio/vertx/core/Vertx;Lio/vertx/pgclient/PgConnectOptions;Lio/vertx/core/Handler;)V
         1: .line 172
            return
        end local 1 // io.vertx.core.Handler completionHandler
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0    2     0               this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0    2     1  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
                   Name  Flags
      completionHandler  

  private synchronized void handleConnectResult(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>, io.vertx.core.AsyncResult<io.vertx.pgclient.PgConnection>);
    descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
    flags: (0x0022) ACC_PRIVATE, ACC_SYNCHRONIZED
    Code:
      stack=4, locals=7, args_size=3
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 1 // io.vertx.core.Handler completionHandler
        start local 2 // io.vertx.core.AsyncResult ar1
         0: .line 175
            aload 0 /* this */
            iconst_0
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.connecting:Z
         1: .line 176
            aload 2 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.succeeded:()Z
            ifeq 20
         2: .line 177
            aload 0 /* this */
            aload 2 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.result:()Ljava/lang/Object;
            checkcast io.vertx.pgclient.PgConnection
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.conn:Lio/vertx/pgclient/PgConnection;
         3: .line 178
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.conn:Lio/vertx/pgclient/PgConnection;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;)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/pgclient/impl/pubsub/PgSubscriberImpl.handleNotification(Lio/vertx/pgclient/PgNotification;)V (7)
                  (Lio/vertx/pgclient/PgNotification;)V
            invokeinterface io.vertx.pgclient.PgConnection.notificationHandler:(Lio/vertx/core/Handler;)Lio/vertx/pgclient/PgConnection;
            pop
         4: .line 179
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.conn:Lio/vertx/pgclient/PgConnection;
            aload 0 /* this */
            invokedynamic handle(Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;)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/pgclient/impl/pubsub/PgSubscriberImpl.handleClose(Ljava/lang/Void;)V (7)
                  (Ljava/lang/Void;)V
            invokeinterface io.vertx.pgclient.PgConnection.closeHandler:(Lio/vertx/core/Handler;)Lio/vertx/pgclient/PgConnection;
            pop
         5: .line 180
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.channels:Ljava/util/Map;
            invokeinterface java.util.Map.size:()I
            ifle 20
         6: .line 181
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.channels:Ljava/util/Map;
            invokeinterface java.util.Map.values:()Ljava/util/Collection;
         7: .line 182
            invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
         8: .line 183
            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/pgclient/impl/pubsub/PgSubscriberImpl.lambda$12(Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;)Ljava/util/stream/Stream; (6)
                  (Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;)Ljava/util/stream/Stream;
            invokeinterface java.util.stream.Stream.flatMap:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
         9: .line 184
            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/pgclient/impl/pubsub/PgSubscriberImpl.lambda$13(Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelImpl;)Lio/vertx/core/Handler; (6)
                  (Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelImpl;)Lio/vertx/core/Handler;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
        10: .line 185
            invokedynamic test()Ljava/util/function/Predicate;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Z
                  java/util/Objects.nonNull(Ljava/lang/Object;)Z (6)
                  (Lio/vertx/core/Handler;)Z
            invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
        11: .line 186
            invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
            invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
            checkcast java.util.List
        12: .line 181
            astore 5 /* handlers */
        start local 5 // java.util.List handlers
        13: .line 187
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.channels:Ljava/util/Map;
            invokeinterface java.util.Map.values:()Ljava/util/Collection;
        14: .line 188
            invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
        15: .line 189
            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/pgclient/impl/pubsub/PgSubscriberImpl.lambda$15(Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;)Ljava/lang/String; (6)
                  (Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;)Ljava/lang/String;
            invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
        16: .line 193
            ldc ";LISTEN "
            ldc "LISTEN "
            ldc ""
            invokestatic java.util.stream.Collectors.joining:(Ljava/lang/CharSequence;Ljava/lang/CharSequence;Ljava/lang/CharSequence;)Ljava/util/stream/Collector;
            invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
            checkcast java.lang.String
        17: .line 187
            astore 6 /* sql */
        start local 6 // java.lang.String sql
        18: .line 194
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.conn:Lio/vertx/pgclient/PgConnection;
            aload 6 /* sql */
            invokeinterface io.vertx.pgclient.PgConnection.query:(Ljava/lang/String;)Lio/vertx/sqlclient/Query;
            aload 0 /* this */
            aload 5 /* handlers */
            aload 1 /* completionHandler */
            invokedynamic handle(Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;Ljava/util/List;Lio/vertx/core/Handler;)Lio/vertx/core/Handler;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/pgclient/impl/pubsub/PgSubscriberImpl.lambda$16(Ljava/util/List;Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V (7)
                  (Lio/vertx/core/AsyncResult;)V
            invokeinterface io.vertx.sqlclient.Query.execute:(Lio/vertx/core/Handler;)V
        19: .line 203
            return
        end local 6 // java.lang.String sql
        end local 5 // java.util.List handlers
        20: .line 206
      StackMap locals:
      StackMap stack:
            aload 1 /* completionHandler */
            aload 2 /* ar1 */
            invokeinterface io.vertx.core.AsyncResult.mapEmpty:()Lio/vertx/core/AsyncResult;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
        21: .line 207
            return
        end local 2 // io.vertx.core.AsyncResult ar1
        end local 1 // io.vertx.core.Handler completionHandler
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   22     0               this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0   22     1  completionHandler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
            0   22     2                ar1  Lio/vertx/core/AsyncResult<Lio/vertx/pgclient/PgConnection;>;
           13   20     5           handlers  Ljava/util/List<Lio/vertx/core/Handler<Ljava/lang/Void;>;>;
           18   20     6                sql  Ljava/lang/String;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;Lio/vertx/core/AsyncResult<Lio/vertx/pgclient/PgConnection;>;)V
    MethodParameters:
                   Name  Flags
      completionHandler  
      ar1                

  public io.vertx.core.Future<java.lang.Void> close();
    descriptor: ()Lio/vertx/core/Future;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
         0: .line 338
            aload 0 /* this */
            dup
            astore 1
            monitorenter
         1: .line 339
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.closed:Z
            ifne 6
         2: .line 340
            aload 0 /* this */
            iconst_1
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.closed:Z
         3: .line 341
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.conn:Lio/vertx/pgclient/PgConnection;
            ifnull 6
         4: .line 342
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.conn:Lio/vertx/pgclient/PgConnection;
            invokeinterface io.vertx.pgclient.PgConnection.close:()Lio/vertx/core/Future;
            aload 1
            monitorexit
         5: areturn
         6: .line 338
      StackMap locals: io.vertx.pgclient.impl.pubsub.PgSubscriberImpl
      StackMap stack:
            aload 1
            monitorexit
         7: goto 10
      StackMap locals:
      StackMap stack: java.lang.Throwable
         8: aload 1
            monitorexit
         9: athrow
        10: .line 346
      StackMap locals:
      StackMap stack:
            invokestatic io.vertx.core.Future.succeededFuture:()Lio/vertx/core/Future;
            areturn
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   11     0  this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
      Exception table:
        from    to  target  type
           1     5       8  any
           6     7       8  any
           8     9       8  any
    Signature: ()Lio/vertx/core/Future<Ljava/lang/Void;>;

  public void close(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 1 // io.vertx.core.Handler handler
         0: .line 351
            aload 0 /* this */
            invokevirtual io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.close:()Lio/vertx/core/Future;
            aload 1 /* handler */
            invokeinterface io.vertx.core.Future.onComplete:(Lio/vertx/core/Handler;)Lio/vertx/core/Future;
            pop
         1: .line 352
            return
        end local 1 // io.vertx.core.Handler handler
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0     this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0    2     1  handler  Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;
    Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)V
    MethodParameters:
         Name  Flags
      handler  

  public io.vertx.pgclient.pubsub.PgChannel channel(java.lang.String);
    descriptor: (Ljava/lang/String;)Lio/vertx/pgclient/pubsub/PgChannel;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 1 // java.lang.String name
         0: .line 356
            new io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl
            dup
            aload 0 /* this */
            aload 1 /* name */
            invokespecial io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl.<init>:(Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;Ljava/lang/String;)V
            areturn
        end local 1 // java.lang.String name
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0    1     1  name  Ljava/lang/String;
    MethodParameters:
      Name  Flags
      name  

  private static java.lang.Long lambda$0(java.lang.Integer);
    descriptor: (Ljava/lang/Integer;)Ljava/lang/Long;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Integer count
         0: .line 34
            ldc -1
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            areturn
        end local 0 // java.lang.Integer count
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    1     0  count  Ljava/lang/Integer;

  private static void lambda$1(java.util.List, io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl);
    descriptor: (Ljava/util/List;Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelImpl;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=2
        start local 1 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl sub
         0: .line 66
            aload 1 /* sub */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl.paused:Z
            ifne 4
         1: .line 67
            aload 1 /* sub */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl.eventHandler:Lio/vertx/core/Handler;
            astore 2 /* handler */
        start local 2 // io.vertx.core.Handler handler
         2: .line 68
            aload 2 /* handler */
            ifnull 4
         3: .line 69
            aload 0
            aload 2 /* handler */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 2 // io.vertx.core.Handler handler
         4: .line 74
      StackMap locals:
      StackMap stack:
            return
        end local 1 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl sub
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    5     1      sub  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelImpl;
            2    4     2  handler  Lio/vertx/core/Handler<Ljava/lang/String;>;

  private static void lambda$2(io.vertx.pgclient.PgNotification, io.vertx.core.Handler);
    descriptor: (Lio/vertx/pgclient/PgNotification;Lio/vertx/core/Handler;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
        start local 1 // io.vertx.core.Handler handler
         0: .line 80
            aload 1 /* handler */
            aload 0
            invokevirtual io.vertx.pgclient.PgNotification.getPayload:()Ljava/lang/String;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         1: .line 81
            return
        end local 1 // io.vertx.core.Handler handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     1  handler  Lio/vertx/core/Handler<Ljava/lang/String;>;

  private void lambda$3(int, io.vertx.core.AsyncResult);
    descriptor: (ILio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 2 // io.vertx.core.AsyncResult ar
         0: .line 110
            aload 2 /* ar */
            invokeinterface io.vertx.core.AsyncResult.failed:()Z
            ifeq 2
         1: .line 111
            aload 0 /* this */
            iload 1
            iconst_1
            iadd
            invokevirtual io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.checkReconnect:(I)V
         2: .line 113
      StackMap locals:
      StackMap stack:
            return
        end local 2 // io.vertx.core.AsyncResult ar
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    3     0  this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0    3     2    ar  Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;

  private static java.util.stream.Stream lambda$4(io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList);
    descriptor: (Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;)Ljava/util/stream/Stream;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList channel
         0: .line 121
            aload 0 /* channel */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList.subs:Ljava/util/ArrayList;
            invokevirtual java.util.ArrayList.stream:()Ljava/util/stream/Stream;
            areturn
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList channel
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0  channel  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;

  private static io.vertx.core.Handler lambda$5(io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl);
    descriptor: (Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelImpl;)Lio/vertx/core/Handler;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl sub
         0: .line 122
            aload 0 /* sub */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl.endHandler:Lio/vertx/core/Handler;
            areturn
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl sub
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0   sub  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelImpl;

  private static void lambda$7(io.vertx.core.Handler);
    descriptor: (Lio/vertx/core/Handler;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.core.Handler handler
         0: .line 126
            aload 0 /* handler */
            aconst_null
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
            return
        end local 0 // io.vertx.core.Handler handler
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0  handler  Lio/vertx/core/Handler<Ljava/lang/Void;>;

  private void lambda$8(io.vertx.core.Handler, java.lang.Long);
    descriptor: (Lio/vertx/core/Handler;Ljava/lang/Long;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 2 // java.lang.Long v
         0: .line 163
            aload 0 /* this */
            aload 1
            invokevirtual io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.doConnect:(Lio/vertx/core/Handler;)V
            return
        end local 2 // java.lang.Long v
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0    1     2     v  Ljava/lang/Long;

  private void lambda$9(io.vertx.core.Handler, io.vertx.core.AsyncResult);
    descriptor: (Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 2 // io.vertx.core.AsyncResult ar
         0: .line 171
            aload 0 /* this */
            aload 1
            aload 2 /* ar */
            invokevirtual io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.handleConnectResult:(Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
            return
        end local 2 // io.vertx.core.AsyncResult ar
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0    1     2    ar  Lio/vertx/core/AsyncResult<Lio/vertx/pgclient/PgConnection;>;

  private static java.util.stream.Stream lambda$12(io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList);
    descriptor: (Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;)Ljava/util/stream/Stream;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList channel
         0: .line 183
            aload 0 /* channel */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList.subs:Ljava/util/ArrayList;
            invokevirtual java.util.ArrayList.stream:()Ljava/util/stream/Stream;
            areturn
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList channel
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0  channel  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;

  private static io.vertx.core.Handler lambda$13(io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl);
    descriptor: (Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelImpl;)Lio/vertx/core/Handler;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl sub
         0: .line 184
            aload 0 /* sub */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl.subscribeHandler:Lio/vertx/core/Handler;
            areturn
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl sub
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0   sub  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelImpl;

  private static java.lang.String lambda$15(io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList);
    descriptor: (Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;)Ljava/lang/String;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList channel
         0: .line 190
            aload 0 /* channel */
            iconst_1
            putfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList.subscribed:Z
         1: .line 191
            aload 0 /* channel */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList.quotedName:Ljava/lang/String;
            areturn
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList channel
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    2     0  channel  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl$ChannelList;

  private void lambda$16(java.util.List, io.vertx.core.Handler, io.vertx.core.AsyncResult);
    descriptor: (Ljava/util/List;Lio/vertx/core/Handler;Lio/vertx/core/AsyncResult;)V
    flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
    Code:
      stack=3, locals=4, args_size=4
        start local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
        start local 3 // io.vertx.core.AsyncResult ar2
         0: .line 195
            aload 3 /* ar2 */
            invokeinterface io.vertx.core.AsyncResult.failed:()Z
            ifeq 4
         1: .line 196
            getstatic io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.log:Lio/vertx/core/impl/logging/Logger;
            ldc "Cannot LISTEN to channels"
            aload 3 /* ar2 */
            invokeinterface io.vertx.core.AsyncResult.cause:()Ljava/lang/Throwable;
            invokeinterface io.vertx.core.impl.logging.Logger.error:(Ljava/lang/Object;Ljava/lang/Throwable;)V
         2: .line 197
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.conn:Lio/vertx/pgclient/PgConnection;
            invokeinterface io.vertx.pgclient.PgConnection.close:()Lio/vertx/core/Future;
            pop
         3: .line 198
            goto 5
         4: .line 199
      StackMap locals:
      StackMap stack:
            aload 1
            aload 0 /* this */
            getfield io.vertx.pgclient.impl.pubsub.PgSubscriberImpl.vertx:Lio/vertx/core/Vertx;
            dup
            invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
            pop
            invokedynamic accept(Lio/vertx/core/Vertx;)Ljava/util/function/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  io/vertx/core/Vertx.runOnContext(Lio/vertx/core/Handler;)V (9 itf)
                  (Lio/vertx/core/Handler;)V
            invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
         5: .line 201
      StackMap locals:
      StackMap stack:
            aload 2
            aload 3 /* ar2 */
            invokeinterface io.vertx.core.AsyncResult.mapEmpty:()Lio/vertx/core/AsyncResult;
            invokeinterface io.vertx.core.Handler.handle:(Ljava/lang/Object;)V
         6: .line 202
            return
        end local 3 // io.vertx.core.AsyncResult ar2
        end local 0 // io.vertx.pgclient.impl.pubsub.PgSubscriberImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lio/vertx/pgclient/impl/pubsub/PgSubscriberImpl;
            0    7     3   ar2  Lio/vertx/core/AsyncResult<Lio/vertx/sqlclient/RowSet<Lio/vertx/sqlclient/Row;>;>;
}
SourceFile: "PgSubscriberImpl.java"
NestMembers:
  io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl  io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList
InnerClasses:
  private ChannelImpl = io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelImpl of io.vertx.pgclient.impl.pubsub.PgSubscriberImpl
  private ChannelList = io.vertx.pgclient.impl.pubsub.PgSubscriberImpl$ChannelList of io.vertx.pgclient.impl.pubsub.PgSubscriberImpl
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles