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: 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"