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, waitSE
close, close, closeStatus, isOpen
protected final Log logger
protected AbstractWebSocketSession(T delegate, StringSE id, HandshakeInfo info, DataBufferFactory bufferFactory)
protected T getDelegate()
public StringSE getId()
WebSocketSession
WebSocketSession
の getId
public HandshakeInfo getHandshakeInfo()
WebSocketSession
WebSocketSession
の getHandshakeInfo
public DataBufferFactory bufferFactory()
WebSocketSession
DataBuffer
ファクトリを返します。WebSocketSession
の bufferFactory
public MapSE<StringSE,ObjectSE> getAttributes()
WebSocketSession
WebSocketSession
の 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)
WebSocketSession
Mono<Void>
を返します。 セッションの処理方法の詳細と例については、WebSocketHandler
のクラスレベルのドキュメントとリファレンスを参照してください。
WebSocketSession
の send
public WebSocketMessage textMessage(StringSE payload)
WebSocketSession
WebSocketSession.bufferFactory()
を使用してテキスト WebSocketMessage
を作成するファクトリメソッド。WebSocketSession
の textMessage
public WebSocketMessage binaryMessage(FunctionSE<DataBufferFactory,DataBuffer> payloadFactory)
WebSocketSession
WebSocketSession.bufferFactory()
を使用してバイナリ WebSocketMessage を作成するファクトリメソッド。WebSocketSession
の binaryMessage
public WebSocketMessage pingMessage(FunctionSE<DataBufferFactory,DataBuffer> payloadFactory)
WebSocketSession
WebSocketSession.bufferFactory()
を使用して ping WebSocketMessage を作成するファクトリメソッド。WebSocketSession
の pingMessage
public WebSocketMessage pongMessage(FunctionSE<DataBufferFactory,DataBuffer> payloadFactory)
WebSocketSession
WebSocketSession.bufferFactory()
を使用してポン WebSocketMessage を作成するファクトリメソッド。WebSocketSession
の pongMessage
public StringSE toString()
ObjectSE
の toStringSE