public interface io.micronaut.websocket.RxWebSocketClient extends io.micronaut.websocket.WebSocketClient
minor version: 0
major version: 59
flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
this_class: io.micronaut.websocket.RxWebSocketClient
super_class: java.lang.Object
{
public abstract <T extends java.lang.AutoCloseable> io.reactivex.Flowable<T> connect(java.lang.Class<T>, io.micronaut.http.MutableHttpRequest<?>);
descriptor: (Ljava/lang/Class;Lio/micronaut/http/MutableHttpRequest;)Lio/reactivex/Flowable;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: <T::Ljava/lang/AutoCloseable;>(Ljava/lang/Class<TT;>;Lio/micronaut/http/MutableHttpRequest<*>;)Lio/reactivex/Flowable<TT;>;
MethodParameters:
Name Flags
clientEndpointType
request
public <T extends java.lang.AutoCloseable> io.reactivex.Flowable<T> connect(java.lang.Class<T>, java.net.URI);
descriptor: (Ljava/lang/Class;Ljava/net/URI;)Lio/reactivex/Flowable;
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
invokespecial io.micronaut.websocket.WebSocketClient.connect:(Ljava/lang/Class;Ljava/net/URI;)Lorg/reactivestreams/Publisher;
checkcast io.reactivex.Flowable
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/micronaut/websocket/RxWebSocketClient;
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;)Lio/reactivex/Flowable<TT;>;
MethodParameters:
Name Flags
clientEndpointType
uri
public abstract <T extends java.lang.AutoCloseable> io.reactivex.Flowable<T> connect(java.lang.Class<T>, java.util.Map<java.lang.String, java.lang.Object>);
descriptor: (Ljava/lang/Class;Ljava/util/Map;)Lio/reactivex/Flowable;
flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
Signature: <T::Ljava/lang/AutoCloseable;>(Ljava/lang/Class<TT;>;Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;)Lio/reactivex/Flowable<TT;>;
MethodParameters:
Name Flags
clientEndpointType
parameters
public <T extends java.lang.AutoCloseable> io.reactivex.Flowable<T> connect(java.lang.Class<T>, java.lang.String);
descriptor: (Ljava/lang/Class;Ljava/lang/String;)Lio/reactivex/Flowable;
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
invokespecial io.micronaut.websocket.WebSocketClient.connect:(Ljava/lang/Class;Ljava/lang/String;)Lorg/reactivestreams/Publisher;
checkcast io.reactivex.Flowable
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/micronaut/websocket/RxWebSocketClient;
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;)Lio/reactivex/Flowable<TT;>;
MethodParameters:
Name Flags
clientEndpointType
uri
public org.reactivestreams.Publisher connect(java.lang.Class, java.lang.String);
descriptor: (Ljava/lang/Class;Ljava/lang/String;)Lorg/reactivestreams/Publisher;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
checkcast java.lang.Class
aload 2
invokeinterface io.micronaut.websocket.RxWebSocketClient.connect:(Ljava/lang/Class;Ljava/lang/String;)Lio/reactivex/Flowable;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.reactivestreams.Publisher connect(java.lang.Class, java.util.Map);
descriptor: (Ljava/lang/Class;Ljava/util/Map;)Lorg/reactivestreams/Publisher;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
checkcast java.lang.Class
aload 2
invokeinterface io.micronaut.websocket.RxWebSocketClient.connect:(Ljava/lang/Class;Ljava/util/Map;)Lio/reactivex/Flowable;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.reactivestreams.Publisher connect(java.lang.Class, java.net.URI);
descriptor: (Ljava/lang/Class;Ljava/net/URI;)Lorg/reactivestreams/Publisher;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
checkcast java.lang.Class
aload 2
invokeinterface io.micronaut.websocket.RxWebSocketClient.connect:(Ljava/lang/Class;Ljava/net/URI;)Lio/reactivex/Flowable;
areturn
LocalVariableTable:
Start End Slot Name Signature
public org.reactivestreams.Publisher connect(java.lang.Class, io.micronaut.http.MutableHttpRequest);
descriptor: (Ljava/lang/Class;Lio/micronaut/http/MutableHttpRequest;)Lorg/reactivestreams/Publisher;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
0: aload 0
aload 1
checkcast java.lang.Class
aload 2
invokeinterface io.micronaut.websocket.RxWebSocketClient.connect:(Ljava/lang/Class;Lio/micronaut/http/MutableHttpRequest;)Lio/reactivex/Flowable;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "RxWebSocketClient.java"