protected final class AbstractListenerWebSocketSession.WebSocketSendProcessor extends AbstractListenerWriteProcessor<WebSocketMessage>
rsWriteLogger
修飾子と型 | メソッドと説明 |
---|---|
protected void | discardData(WebSocketMessage message) エラー(アップストリーム書き込みパブリッシャーから、または基になるサーバーへの I/O 操作から)の後に呼び出され、エラーが発生したときに書き込まれていた処理中のデータを破棄するためのキャンセル。 |
protected boolean | isDataEmpty(WebSocketMessage message) 指定されたデータ項目に書き込む内容があるかどうか。 |
protected boolean | isWritePossible() 書き込み可能かどうか。 |
void | setReadyToSend(boolean ready) サブクラスは、メッセージを送信する前(false)および非同期送信コールバックを受信した後(true)に、非同期完了コールバックを単純なフロー制御に効果的に変換してこれを呼び出すことができます。 |
protected boolean | write(WebSocketMessage message) 与えられたアイテムを書いてください。 |
cancel, dataReceived, getLogPrefix, onComplete, onError, onNext, onSubscribe, onWritePossible, subscribe, writingComplete, writingFailed, writingPaused
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
protected boolean write(WebSocketMessage message) throws IOExceptionSE
AbstractListenerWriteProcessor
注意 : プールされたバッファーが基になるコンテナーに適用される場合、サブクラスは、完全に書き込まれた後、アイテムに関連付けられたデータバッファーを解放する必要があります。
AbstractListenerWriteProcessor<WebSocketMessage>
の write
message
- 書き込むアイテム true
、部分的に書き込まれた場合は false
であり、完全に書き込まれる前にさらに書き込みコールバックが必要になります IOExceptionSE
protected boolean isDataEmpty(WebSocketMessage message)
AbstractListenerWriteProcessor
AbstractListenerWriteProcessor<WebSocketMessage>
の isDataEmpty
protected boolean isWritePossible()
AbstractListenerWriteProcessor
public void setReadyToSend(boolean ready)
protected void discardData(WebSocketMessage message)
AbstractListenerWriteProcessor
AbstractListenerWriteProcessor<WebSocketMessage>
の discardData
message
- リリースされるデータ