T - ネイティブデリゲート型 public abstract class AbstractWebSocketSession<T> extends ObjectSE implements WebSocketSession
WebSocketSession 実装の便利な基本クラス。WebSocketMessage ファクトリメソッドも実装します。| 修飾子 | コンストラクターと説明 |
|---|---|
protected | AbstractWebSocketSession(T delegate, StringSE id, HandshakeInfo info, DataBufferFactory bufferFactory) 新しい WebSocket セッションを作成します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
WebSocketMessage | binaryMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションに WebSocketSession.bufferFactory() を使用してバイナリ WebSocketMessage を作成するファクトリメソッド。 |
DataBufferFactory | bufferFactory() メッセージペイロードを作成する DataBuffer ファクトリを返します。 |
MapSE<StringSE, ObjectSE> | getAttributes()WebSocket セッションに関連付けられた属性を持つマップを返します。 |
protected T | getDelegate() |
HandshakeInfo | getHandshakeInfo() ハンドシェイクリクエストから情報を返します。 |
StringSE | getId() セッションの ID を返します。 |
protected StringSE | getLogPrefix() |
WebSocketMessage | pingMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションに WebSocketSession.bufferFactory() を使用して ping WebSocketMessage を作成するファクトリメソッド。 |
WebSocketMessage | pongMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションに WebSocketSession.bufferFactory() を使用してポン WebSocketMessage を作成するファクトリメソッド。 |
abstract reactor.core.publisher.Flux<WebSocketMessage> | receive() 受信メッセージのストリームへのアクセスを提供します。 |
abstract reactor.core.publisher.Mono<VoidSE> | send(Publisher<WebSocketMessage> messages) 発信メッセージのソースを提供し、メッセージを書き込み、ソースが完了して書き込みが完了すると完了する Mono<Void> を返します。 |
WebSocketMessage | textMessage(StringSE payload) セッションに WebSocketSession.bufferFactory() を使用してテキスト WebSocketMessage を作成するファクトリメソッド。 |
StringSE | toString() |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEclose, close, closeStatus, isOpenprotected final Log logger
protected AbstractWebSocketSession(T delegate, StringSE id, HandshakeInfo info, DataBufferFactory bufferFactory)
protected T getDelegate()
public StringSE getId()
WebSocketSessionWebSocketSession の getId public HandshakeInfo getHandshakeInfo()
WebSocketSessionWebSocketSession の getHandshakeInfo public DataBufferFactory bufferFactory()
WebSocketSessionDataBuffer ファクトリを返します。WebSocketSession の bufferFactory public MapSE<StringSE,ObjectSE> getAttributes()
WebSocketSessionWebSocketSession の getAttributes null)protected StringSE getLogPrefix()
public abstract reactor.core.publisher.Flux<WebSocketMessage> receive()
WebSocketSession このストリームは、接続が閉じられたときに完了またはエラーシグナルを受け取ります。典型的な WebSocketHandler 実装では、このストリームは全体的な処理フローに組み込まれるため、接続が閉じられると処理が終了します。
セッションの処理方法の詳細と例については、WebSocketHandler のクラスレベルのドキュメントとリファレンスを参照してください。
WebSocketSession の receive public abstract reactor.core.publisher.Mono<VoidSE> send(Publisher<WebSocketMessage> messages)
WebSocketSessionMono<Void> を返します。 セッションの処理方法の詳細と例については、WebSocketHandler のクラスレベルのドキュメントとリファレンスを参照してください。
WebSocketSession の send public WebSocketMessage textMessage(StringSE payload)
WebSocketSessionWebSocketSession.bufferFactory() を使用してテキスト WebSocketMessage を作成するファクトリメソッド。WebSocketSession の textMessage public WebSocketMessage binaryMessage(FunctionSE<DataBufferFactory,DataBuffer> payloadFactory)
WebSocketSessionWebSocketSession.bufferFactory() を使用してバイナリ WebSocketMessage を作成するファクトリメソッド。WebSocketSession の binaryMessage public WebSocketMessage pingMessage(FunctionSE<DataBufferFactory,DataBuffer> payloadFactory)
WebSocketSessionWebSocketSession.bufferFactory() を使用して ping WebSocketMessage を作成するファクトリメソッド。WebSocketSession の pingMessage public WebSocketMessage pongMessage(FunctionSE<DataBufferFactory,DataBuffer> payloadFactory)
WebSocketSessionWebSocketSession.bufferFactory() を使用してポン WebSocketMessage を作成するファクトリメソッド。WebSocketSession の pongMessage public StringSE toString()
ObjectSE の toStringSE