private final class AbstractListenerWebSocketSession.WebSocketReceivePublisher extends AbstractListenerReadPublisher<WebSocketMessage>
Modifier and Type | Field and Description |
---|---|
private WebSocketMessage |
webSocketMessage |
logger
Modifier | Constructor and Description |
---|---|
private |
WebSocketReceivePublisher() |
Modifier and Type | Method and Description |
---|---|
protected void |
checkOnDataAvailable() |
(package private) void |
handleMessage(WebSocketMessage webSocketMessage) |
protected WebSocketMessage |
read()
Reads a data from the input, if possible.
|
onAllDataRead, onDataAvailable, onError, subscribe
@Nullable private volatile WebSocketMessage webSocketMessage
protected void checkOnDataAvailable()
checkOnDataAvailable
in class AbstractListenerReadPublisher<WebSocketMessage>
@Nullable protected WebSocketMessage read() throws java.io.IOException
AbstractListenerReadPublisher
read
in class AbstractListenerReadPublisher<WebSocketMessage>
null
java.io.IOException
void handleMessage(WebSocketMessage webSocketMessage)