public class ReactorNettyWebSocketSession extends NettyWebSocketSessionSupport<ReactorNettyWebSocketSession.WebSocketConnection>
修飾子と型 | クラスと説明 |
---|---|
static class | ReactorNettyWebSocketSession.WebSocketConnection NettyInbound および NettyOutbound のシンプルなコンテナー。 |
DEFAULT_FRAME_MAX_SIZE
logger
コンストラクターと説明 |
---|
ReactorNettyWebSocketSession(reactor.netty.http.websocket.WebsocketInbound inbound, reactor.netty.http.websocket.WebsocketOutbound outbound, HandshakeInfo info, NettyDataBufferFactory bufferFactory) NettyWebSocketSessionSupport.DEFAULT_FRAME_MAX_SIZE 値を使用するセッションのコンストラクター。 |
ReactorNettyWebSocketSession(reactor.netty.http.websocket.WebsocketInbound inbound, reactor.netty.http.websocket.WebsocketOutbound outbound, HandshakeInfo info, NettyDataBufferFactory bufferFactory, int maxFramePayloadLength) 追加の maxFramePayloadLength 引数を持つコンストラクター。 |
修飾子と型 | メソッドと説明 |
---|---|
reactor.core.publisher.Mono<VoidSE> | close(CloseStatus status) 指定されたステータスで WebSocket セッションを閉じます。 |
reactor.core.publisher.Mono<CloseStatus> | closeStatus() セッションがローカルまたはリモートで閉じられる CloseStatus へのアクセスを提供します。セッションがステータスなしで終了した場合は、空になります。 |
io.netty.channel.ChannelId | getChannelId() 基になる Netty チャネルの ID を返します。 |
boolean | isOpen() 基になる接続が開いているかどうか。 |
reactor.core.publisher.Flux<WebSocketMessage> | receive() 受信メッセージのストリームへのアクセスを提供します。 |
reactor.core.publisher.Mono<VoidSE> | send(Publisher<WebSocketMessage> messages) 発信メッセージのソースを提供し、メッセージを書き込み、ソースが完了して書き込みが完了すると完了する Mono<Void> を返します。 |
bufferFactory, toFrame, toMessage
binaryMessage, getAttributes, getDelegate, getHandshakeInfo, getId, getLogPrefix, pingMessage, pongMessage, textMessage, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
close
public ReactorNettyWebSocketSession(reactor.netty.http.websocket.WebsocketInbound inbound, reactor.netty.http.websocket.WebsocketOutbound outbound, HandshakeInfo info, NettyDataBufferFactory bufferFactory)
NettyWebSocketSessionSupport.DEFAULT_FRAME_MAX_SIZE
値を使用するセッションのコンストラクター。public ReactorNettyWebSocketSession(reactor.netty.http.websocket.WebsocketInbound inbound, reactor.netty.http.websocket.WebsocketOutbound outbound, HandshakeInfo info, NettyDataBufferFactory bufferFactory, int maxFramePayloadLength)
public io.netty.channel.ChannelId getChannelId()
public reactor.core.publisher.Flux<WebSocketMessage> receive()
WebSocketSession
このストリームは、接続が閉じられたときに完了またはエラー信号を受け取ります。典型的な WebSocketHandler
実装では、このストリームは全体的な処理フローに組み込まれるため、接続が閉じられると処理が終了します。
セッションの処理方法の詳細と例については、WebSocketHandler
のクラスレベルのドキュメントとリファレンスを参照してください。
WebSocketSession
の receive
AbstractWebSocketSession<ReactorNettyWebSocketSession.WebSocketConnection>
の receive
public reactor.core.publisher.Mono<VoidSE> send(Publisher<WebSocketMessage> messages)
WebSocketSession
Mono<Void>
を返します。 セッションの処理方法の詳細と例については、WebSocketHandler
のクラスレベルのドキュメントとリファレンスを参照してください。
WebSocketSession
の send
AbstractWebSocketSession<ReactorNettyWebSocketSession.WebSocketConnection>
の send
public boolean isOpen()
WebSocketSession
public reactor.core.publisher.Mono<VoidSE> close(CloseStatus status)
WebSocketSession
status
- 終了ステータス public reactor.core.publisher.Mono<CloseStatus> closeStatus()
WebSocketSession
CloseStatus
へのアクセスを提供します。セッションがステータスなしで終了した場合は、空になります。