public interface io.micronaut.websocket.RxWebSocketSession extends io.micronaut.websocket.WebSocketSession
  minor version: 0
  major version: 59
  flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
  this_class: io.micronaut.websocket.RxWebSocketSession
  super_class: java.lang.Object
{
  public abstract java.util.Set<? extends io.micronaut.websocket.RxWebSocketSession> getOpenSessions();
    descriptor: ()Ljava/util/Set;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: ()Ljava/util/Set<+Lio/micronaut/websocket/RxWebSocketSession;>;

  public abstract <T> io.reactivex.Flowable<T> send(T, io.micronaut.http.MediaType);
    descriptor: (Ljava/lang/Object;Lio/micronaut/http/MediaType;)Lio/reactivex/Flowable;
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: <T:Ljava/lang/Object;>(TT;Lio/micronaut/http/MediaType;)Lio/reactivex/Flowable<TT;>;
    MethodParameters:
           Name  Flags
      message    
      mediaType  

  public org.reactivestreams.Publisher send(java.lang.Object, io.micronaut.http.MediaType);
    descriptor: (Ljava/lang/Object;Lio/micronaut/http/MediaType;)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.Object
            aload 2
            invokeinterface io.micronaut.websocket.RxWebSocketSession.send:(Ljava/lang/Object;Lio/micronaut/http/MediaType;)Lio/reactivex/Flowable;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
SourceFile: "RxWebSocketSession.java"