public class UndertowWebSocketSession extends AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel>
WebSocketChannel に適応する Spring WebSocketSession 実装。AbstractListenerWebSocketSession.WebSocketSendProcessor| コンストラクターと説明 |
|---|
UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel, HandshakeInfo info, DataBufferFactory factory) |
UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel, HandshakeInfo info, DataBufferFactory factory, reactor.core.publisher.MonoProcessor<java.lang.Void> completionMono) |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected boolean | canSuspendReceiving() 基礎となる WebSocket API にフロー制御があり、メッセージの受信を一時停止および再開できるかどうか。 |
reactor.core.publisher.Mono<java.lang.Void> | close(CloseStatus status) 指定されたステータスで WebSocket セッションを閉じます。 |
protected void | resumeReceiving() ダウンストリームサブスクライバによって要求が生成された後、新しいメッセージの受信を再開します。 |
protected boolean | sendMessage(WebSocketMessage message) 指定された WebSocket メッセージを送信します。 |
protected void | suspendReceiving() 受信したメッセージが処理され、ダウンストリームサブスクライバーによってより多くの要求が生成されるまで、受信を中断します。 |
getSendProcessor, onComplete, onError, onNext, onSubscribe, receive, sendbinaryMessage, bufferFactory, getDelegate, getHandshakeInfo, getId, pingMessage, pongMessage, textMessage, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitclosepublic UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel,
HandshakeInfo info,
DataBufferFactory factory)public UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel,
HandshakeInfo info,
DataBufferFactory factory,
@Nullable
reactor.core.publisher.MonoProcessor<java.lang.Void> completionMono)protected boolean canSuspendReceiving()
AbstractListenerWebSocketSessionAbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel> の canSuspendReceiving protected void suspendReceiving()
AbstractListenerWebSocketSession 注意 : 基礎となる WebSocket API がメッセージを受信するためのフロー制御を提供せず、このメソッドが何も実行されず、AbstractListenerWebSocketSession.canSuspendReceiving() が false を返す場合。
AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel> の suspendReceiving protected void resumeReceiving()
AbstractListenerWebSocketSession 注意 : 基礎となる WebSocket API がメッセージを受信するためのフロー制御を提供せず、このメソッドが何も実行されず、AbstractListenerWebSocketSession.canSuspendReceiving() が false を返す場合。
AbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel> の resumeReceiving protected boolean sendMessage(WebSocketMessage message) throws java.io.IOException
AbstractListenerWebSocketSessionAbstractListenerWebSocketSession<io.undertow.websockets.core.WebSocketChannel> の sendMessage java.io.IOExceptionpublic reactor.core.publisher.Mono<java.lang.Void> close(CloseStatus status)
WebSocketSessionstatus - 終了ステータス