public class ReactorNettyWebSocketSession extends NettyWebSocketSessionSupport<ReactorNettyWebSocketSession.WebSocketConnection>
Modifier and Type | Class and Description |
---|---|
static class |
ReactorNettyWebSocketSession.WebSocketConnection
Simple container for
NettyInbound and NettyOutbound . |
DEFAULT_FRAME_MAX_SIZE
Constructor and Description |
---|
ReactorNettyWebSocketSession(WebsocketInbound inbound,
WebsocketOutbound outbound,
HandshakeInfo info,
NettyDataBufferFactory bufferFactory) |
Modifier and Type | Method and Description |
---|---|
<any> |
close(CloseStatus status)
Close the WebSocket session with the given status.
|
<any> |
receive()
Get access to the stream of incoming messages.
|
<any> |
send(<any> messages)
Write the given messages to the WebSocket connection.
|
bufferFactory, toFrame, toMessage
binaryMessage, getDelegate, getHandshakeInfo, getId, pingMessage, pongMessage, textMessage, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
close
public ReactorNettyWebSocketSession(WebsocketInbound inbound, WebsocketOutbound outbound, HandshakeInfo info, NettyDataBufferFactory bufferFactory)
public <any> receive()
WebSocketSession
receive
in interface WebSocketSession
receive
in class AbstractWebSocketSession<ReactorNettyWebSocketSession.WebSocketConnection>
public <any> send(<any> messages)
WebSocketSession
send
in interface WebSocketSession
send
in class AbstractWebSocketSession<ReactorNettyWebSocketSession.WebSocketConnection>
messages
- the messages to writepublic <any> close(CloseStatus status)
WebSocketSession
status
- the close status