クラス AbstractListenerWebSocketSession.WebSocketSendProcessor
java.lang.ObjectSE
org.springframework.http.server.reactive.AbstractListenerWriteProcessor<WebSocketMessage>
org.springframework.web.reactive.socket.adapter.AbstractListenerWebSocketSession.WebSocketSendProcessor
- 実装されたすべてのインターフェース:
Processor<WebSocketMessage,
、VoidSE> Publisher<VoidSE>
、Subscriber<WebSocketMessage>
- 含まれているクラス:
- AbstractListenerWebSocketSession<T>
protected final class AbstractListenerWebSocketSession.WebSocketSendProcessor
extends AbstractListenerWriteProcessor<WebSocketMessage>
送信 WebSocket メッセージ用の書き込みプロセッサー。
フィールドサマリー
クラス org.springframework.http.server.reactive.AbstractListenerWriteProcessor から継承されたフィールド
rsWriteLogger
メソッドのサマリー
修飾子と型メソッド説明protected void
discardData
(WebSocketMessage message) エラー(アップストリーム書き込みパブリッシャーから、または基になるサーバーへの I/O 操作から)の後に呼び出され、エラーが発生したときに書き込まれていた処理中のデータを破棄するためのキャンセル。protected boolean
isDataEmpty
(WebSocketMessage message) 指定されたデータ項目に書き込む内容があるかどうか。protected boolean
書き込み可能かどうか。void
setReadyToSend
(boolean ready) サブクラスは、メッセージを送信する前 (false)、および非同期送信コールバックを受信した後 (true) にこれを呼び出して、非同期完了コールバックを単純なフロー制御に効果的に変換できます。protected boolean
write
(WebSocketMessage message) 与えられたアイテムを書いてください。クラス org.springframework.http.server.reactive.AbstractListenerWriteProcessor から継承されたメソッド
cancel, dataReceived, getLogPrefix, onComplete, onError, onNext, onSubscribe, onWritePossible, subscribe, writingComplete, writingFailed, writingPaused
メソッドの詳細
write
クラスからコピーされた説明:AbstractListenerWriteProcessor
与えられたアイテムを書いてください。注意 : プールされたバッファーが基になるコンテナーに適用される場合、サブクラスは、完全に書き込まれた後、アイテムに関連付けられたデータバッファーを解放する必要があります。
- 次で指定:
- クラス
AbstractListenerWriteProcessor<WebSocketMessage>
のwrite
- パラメーター:
message
- 書き込むアイテム- 戻り値:
- 現在のデータ項目が完全に書き込まれ、新しい項目がリクエストされた場合は
true
、部分的に書き込まれた場合はfalse
であり、完全に書き込まれる前にさらに書き込みコールバックが必要になります - 例外:
IOExceptionSE
isDataEmpty
クラスからコピーされた説明:AbstractListenerWriteProcessor
指定されたデータ項目に書き込む内容があるかどうか。false の場合、アイテムは書き込まれません。- 次で指定:
- クラス
AbstractListenerWriteProcessor<WebSocketMessage>
のisDataEmpty
isWritePossible
protected boolean isWritePossible()クラスからコピーされた説明:AbstractListenerWriteProcessor
書き込み可能かどうか。setReadyToSend
public void setReadyToSend(boolean ready) サブクラスは、メッセージを送信する前 (false)、および非同期送信コールバックを受信した後 (true) にこれを呼び出して、非同期完了コールバックを単純なフロー制御に効果的に変換できます。discardData
クラスからコピーされた説明:AbstractListenerWriteProcessor
エラー(アップストリーム書き込みパブリッシャーから、または基になるサーバーへの I/O 操作から)の後に呼び出され、エラーが発生したときに書き込まれていた処理中のデータを破棄するためのキャンセル。- 次で指定:
- クラス
AbstractListenerWriteProcessor<WebSocketMessage>
のdiscardData
- パラメーター:
message
- リリースされるデータ