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