public interface io.micronaut.websocket.WebSocketClient extends java.lang.AutoCloseable
minor version: 0
major version: 59
flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
this_class: io.micronaut.websocket.WebSocketClient
super_class: java.lang.Object
{
public static final java.lang.String SCHEME_WS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "ws"
public static final java.lang.String SCHEME_WSS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "wss"
public abstract <T extends java.lang.AutoCloseable> org.reactivestreams.Publisher<T> connect(java.lang.Class<T>, io.micronaut.http.MutableHttpRequest<?>);
descriptor: (Ljava/lang/Class;Lio/micronaut/http/MutableHttpRequest;)Lorg/reactivestreams/Publisher;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: <T::Ljava/lang/AutoCloseable;>(Ljava/lang/Class<TT;>;Lio/micronaut/http/MutableHttpRequest<*>;)Lorg/reactivestreams/Publisher<TT;>;
MethodParameters:
Name Flags
clientEndpointType
request
public abstract <T extends java.lang.AutoCloseable> org.reactivestreams.Publisher<T> connect(java.lang.Class<T>, java.util.Map<java.lang.String, java.lang.Object>);
descriptor: (Ljava/lang/Class;Ljava/util/Map;)Lorg/reactivestreams/Publisher;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: <T::Ljava/lang/AutoCloseable;>(Ljava/lang/Class<TT;>;Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;)Lorg/reactivestreams/Publisher<TT;>;
MethodParameters:
Name Flags
clientEndpointType
parameters
public abstract void close();
descriptor: ()V
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
public <T extends java.lang.AutoCloseable> org.reactivestreams.Publisher<T> connect(java.lang.Class<T>, java.lang.String);
descriptor: (Ljava/lang/Class;Ljava/lang/String;)Lorg/reactivestreams/Publisher;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokestatic java.net.URI.create:(Ljava/lang/String;)Ljava/net/URI;
invokeinterface io.micronaut.websocket.WebSocketClient.connect:(Ljava/lang/Class;Ljava/net/URI;)Lorg/reactivestreams/Publisher;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/micronaut/websocket/WebSocketClient;
0 1 1 clientEndpointType Ljava/lang/Class<TT;>;
0 1 2 uri Ljava/lang/String;
Signature: <T::Ljava/lang/AutoCloseable;>(Ljava/lang/Class<TT;>;Ljava/lang/String;)Lorg/reactivestreams/Publisher<TT;>;
MethodParameters:
Name Flags
clientEndpointType
uri
public <T extends java.lang.AutoCloseable> org.reactivestreams.Publisher<T> connect(java.lang.Class<T>, java.net.URI);
descriptor: (Ljava/lang/Class;Ljava/net/URI;)Lorg/reactivestreams/Publisher;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokestatic io.micronaut.http.HttpRequest.GET:(Ljava/net/URI;)Lio/micronaut/http/MutableHttpRequest;
invokeinterface io.micronaut.websocket.WebSocketClient.connect:(Ljava/lang/Class;Lio/micronaut/http/MutableHttpRequest;)Lorg/reactivestreams/Publisher;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/micronaut/websocket/WebSocketClient;
0 1 1 clientEndpointType Ljava/lang/Class<TT;>;
0 1 2 uri Ljava/net/URI;
Signature: <T::Ljava/lang/AutoCloseable;>(Ljava/lang/Class<TT;>;Ljava/net/URI;)Lorg/reactivestreams/Publisher<TT;>;
MethodParameters:
Name Flags
clientEndpointType
uri
}
SourceFile: "WebSocketClient.java"