protected final class AbstractListenerWebSocketSession.WebSocketSendProcessor extends AbstractListenerWriteProcessor<WebSocketMessage>
Modifier and Type | Field and Description |
---|---|
private boolean |
isReady |
currentData, logger
Modifier | Constructor and Description |
---|---|
protected |
WebSocketSendProcessor() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
isDataEmpty(WebSocketMessage message)
Whether the given data item contains any actual data to be processed.
|
protected boolean |
isWritePossible()
Whether writing is possible.
|
protected void |
releaseData()
Called when the current received data item can be released.
|
void |
setReadyToSend(boolean ready)
Sub-classes can invoke this before sending a message (false) and
after receiving the async send callback (true) effective translating
async completion callback into simple flow control.
|
protected boolean |
write(WebSocketMessage message)
Writes the given data to the output.
|
cancel, onComplete, onError, onNext, onSubscribe, onWritePossible, receiveData, subscribe, suspendWriting, writingComplete, writingFailed
protected boolean write(WebSocketMessage message) throws java.io.IOException
AbstractListenerWriteProcessor
write
in class AbstractListenerWriteProcessor<WebSocketMessage>
message
- the data to writetrue
)
and new data can be requested, or otherwise (false
)java.io.IOException
protected void releaseData()
AbstractListenerWriteProcessor
releaseData
in class AbstractListenerWriteProcessor<WebSocketMessage>
protected boolean isDataEmpty(WebSocketMessage message)
AbstractListenerWriteProcessor
isDataEmpty
in class AbstractListenerWriteProcessor<WebSocketMessage>
protected boolean isWritePossible()
AbstractListenerWriteProcessor
isWritePossible
in class AbstractListenerWriteProcessor<WebSocketMessage>
public void setReadyToSend(boolean ready)