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 // io.micronaut.websocket.RxWebSocketClient this
        start local 1 // java.lang.Class clientEndpointType
        start local 2 // java.net.URI uri
         0: .line 41
            aload 0 /* this */
            aload 1 /* clientEndpointType */
            aload 2 /* uri */
            invokespecial io.micronaut.websocket.WebSocketClient.connect:(Ljava/lang/Class;Ljava/net/URI;)Lorg/reactivestreams/Publisher;
            checkcast io.reactivex.Flowable
            areturn
        end local 2 // java.net.URI uri
        end local 1 // java.lang.Class clientEndpointType
        end local 0 // io.micronaut.websocket.RxWebSocketClient this
      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 // io.micronaut.websocket.RxWebSocketClient this
        start local 1 // java.lang.Class clientEndpointType
        start local 2 // java.lang.String uri
         0: .line 52
            aload 0 /* this */
            aload 1 /* clientEndpointType */
            aload 2 /* uri */
            invokespecial io.micronaut.websocket.WebSocketClient.connect:(Ljava/lang/Class;Ljava/lang/String;)Lorg/reactivestreams/Publisher;
            checkcast io.reactivex.Flowable
            areturn
        end local 2 // java.lang.String uri
        end local 1 // java.lang.Class clientEndpointType
        end local 0 // io.micronaut.websocket.RxWebSocketClient this
      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: .line 1
            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: .line 1
            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: .line 1
            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: .line 1
            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"