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 // io.micronaut.websocket.WebSocketClient this
        start local 1 // java.lang.Class clientEndpointType
        start local 2 // java.lang.String uri
         0: .line 85
            aload 0 /* this */
            aload 1 /* clientEndpointType */
            aload 2 /* uri */
            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 // java.lang.String uri
        end local 1 // java.lang.Class clientEndpointType
        end local 0 // io.micronaut.websocket.WebSocketClient this
      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 // io.micronaut.websocket.WebSocketClient this
        start local 1 // java.lang.Class clientEndpointType
        start local 2 // java.net.URI uri
         0: .line 100
            aload 0 /* this */
            aload 1 /* clientEndpointType */
            aload 2 /* uri */
            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 // java.net.URI uri
        end local 1 // java.lang.Class clientEndpointType
        end local 0 // io.micronaut.websocket.WebSocketClient this
      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"