パッケージ org.springframework.web.reactive.socket.adapter

クラス 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 メッセージ用の書き込みプロセッサー。

  • メソッドの詳細

    • write

      protected boolean write(WebSocketMessage message) throws IOExceptionSE
      クラスからコピーされた説明: AbstractListenerWriteProcessor
      与えられたアイテムを書いてください。

      注意 : プールされたバッファーが基になるコンテナーに適用される場合、サブクラスは、完全に書き込まれた後、アイテムに関連付けられたデータバッファーを解放する必要があります。

      次で指定:
      クラス AbstractListenerWriteProcessor<WebSocketMessage> の write 
      パラメーター:
      message - 書き込むアイテム
      戻り値:
      現在のデータ項目が完全に書き込まれ、新しい項目がリクエストされた場合は true、部分的に書き込まれた場合は false であり、完全に書き込まれる前にさらに書き込みコールバックが必要になります
      例外:
      IOExceptionSE

    • isDataEmpty

      protected boolean isDataEmpty(WebSocketMessage message)
      クラスからコピーされた説明: AbstractListenerWriteProcessor
      指定されたデータ項目に書き込む内容があるかどうか。false の場合、アイテムは書き込まれません。
      次で指定:
      クラス AbstractListenerWriteProcessor<WebSocketMessage> の isDataEmpty 

    • isWritePossible

      protected boolean isWritePossible()
      クラスからコピーされた説明: AbstractListenerWriteProcessor
      書き込み可能かどうか。
      次で指定:
      クラス AbstractListenerWriteProcessor<WebSocketMessage> の isWritePossible 

    • setReadyToSend

      public void setReadyToSend(boolean ready)
      サブクラスは、メッセージを送信する前 (false)、および非同期送信コールバックを受信した後 (true) にこれを呼び出して、非同期完了コールバックを単純なフロー制御に効果的に変換できます。

    • discardData

      protected void discardData(WebSocketMessage message)
      クラスからコピーされた説明: AbstractListenerWriteProcessor
      エラー（アップストリーム書き込みパブリッシャーから、または基になるサーバーへの I/O 操作から）の後に呼び出され、エラーが発生したときに書き込まれていた処理中のデータを破棄するためのキャンセル。
      次で指定:
      クラス AbstractListenerWriteProcessor<WebSocketMessage> の discardData 
      パラメーター:
      message - リリースされるデータ