public interface io.reactiverse.pgclient.pubsub.PgSubscriber
minor version: 0
major version: 59
flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
this_class: io.reactiverse.pgclient.pubsub.PgSubscriber
super_class: java.lang.Object
{
public static io.reactiverse.pgclient.pubsub.PgSubscriber subscriber(io.vertx.core.Vertx, io.reactiverse.pgclient.PgConnectOptions);
descriptor: (Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgConnectOptions;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: new io.reactiverse.pgclient.impl.pubsub.PgSubscriberImpl
dup
aload 0
aload 1
invokespecial io.reactiverse.pgclient.impl.pubsub.PgSubscriberImpl.<init>:(Lio/vertx/core/Vertx;Lio/reactiverse/pgclient/PgConnectOptions;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 vertx Lio/vertx/core/Vertx;
0 1 1 options Lio/reactiverse/pgclient/PgConnectOptions;
MethodParameters:
Name Flags
vertx
options
public abstract io.reactiverse.pgclient.pubsub.PgChannel channel(java.lang.String);
descriptor: (Ljava/lang/String;)Lio/reactiverse/pgclient/pubsub/PgChannel;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
MethodParameters:
Name Flags
name
public abstract io.reactiverse.pgclient.pubsub.PgSubscriber connect(io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>);
descriptor: (Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/vertx/core/Handler<Lio/vertx/core/AsyncResult<Ljava/lang/Void;>;>;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
handler
public abstract io.reactiverse.pgclient.pubsub.PgSubscriber reconnectPolicy(java.util.function.Function<java.lang.Integer, java.lang.Long>);
descriptor: (Ljava/util/function/Function;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Ljava/util/function/Function<Ljava/lang/Integer;Ljava/lang/Long;>;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
policy
public abstract io.reactiverse.pgclient.pubsub.PgSubscriber closeHandler(io.vertx.core.Handler<java.lang.Void>);
descriptor: (Lio/vertx/core/Handler;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: (Lio/vertx/core/Handler<Ljava/lang/Void;>;)Lio/reactiverse/pgclient/pubsub/PgSubscriber;
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.Fluent()
MethodParameters:
Name Flags
handler
public abstract io.reactiverse.pgclient.PgConnection actualConnection();
descriptor: ()Lio/reactiverse/pgclient/PgConnection;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract boolean closed();
descriptor: ()Z
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public abstract void close();
descriptor: ()V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
}
SourceFile: "PgSubscriber.java"
RuntimeVisibleAnnotations:
io.vertx.codegen.annotations.VertxGen()