パッケージ | 説明 |
---|---|
org.springframework.web.reactive.socket | リアクティブ WebSocket 相互作用の抽象化とサポートクラス。 |
org.springframework.web.reactive.socket.adapter | Spring の Reactive WebSocket API を WebSocket ランタイムとの間で適合させるクラス。 |
修飾子と型 | メソッドと説明 |
---|---|
WebSocketMessage | WebSocketSession.binaryMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションに WebSocketSession.bufferFactory() を使用してバイナリ WebSocketMessage を作成するファクトリメソッド。 |
WebSocketMessage | WebSocketSession.pingMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションに WebSocketSession.bufferFactory() を使用して ping WebSocketMessage を作成するファクトリメソッド。 |
WebSocketMessage | WebSocketSession.pongMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) セッションに WebSocketSession.bufferFactory() を使用してポン WebSocketMessage を作成するファクトリメソッド。 |
WebSocketMessage | WebSocketMessage.retain() メッセージペイロードのデータバッファーを保持します。これは、ランタイムで役立ちます(例: |
WebSocketMessage | WebSocketSession.textMessage(StringSE payload) セッションに WebSocketSession.bufferFactory() を使用してテキスト WebSocketMessage を作成するファクトリメソッド。 |
修飾子と型 | メソッドと説明 |
---|---|
reactor.core.publisher.Flux<WebSocketMessage> | WebSocketSession.receive() 受信メッセージのストリームへのアクセスを提供します。 |
修飾子と型 | メソッドと説明 |
---|---|
reactor.core.publisher.Mono<VoidSE> | WebSocketSession.send(Publisher<WebSocketMessage> messages) 発信メッセージのソースを提供し、メッセージを書き込み、ソースが完了して書き込みが完了すると完了する Mono<Void> を返します。 |
修飾子と型 | メソッドと説明 |
---|---|
WebSocketMessage | AbstractWebSocketSession.binaryMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) |
WebSocketMessage | AbstractWebSocketSession.pingMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) |
WebSocketMessage | AbstractWebSocketSession.pongMessage(FunctionSE<DataBufferFactory, DataBuffer> payloadFactory) |
WebSocketMessage | AbstractWebSocketSession.textMessage(StringSE payload) |
protected WebSocketMessage | NettyWebSocketSessionSupport.toMessage(io.netty.handler.codec.http.websocketx.WebSocketFrame frame) |
修飾子と型 | メソッドと説明 |
---|---|
abstract reactor.core.publisher.Flux<WebSocketMessage> | AbstractWebSocketSession.receive() |
reactor.core.publisher.Flux<WebSocketMessage> | AbstractListenerWebSocketSession.receive() |
reactor.core.publisher.Flux<WebSocketMessage> | ReactorNettyWebSocketSession.receive() |
修飾子と型 | メソッドと説明 |
---|---|
protected void | AbstractListenerWebSocketSession.WebSocketSendProcessor.discardData(WebSocketMessage message) |
protected boolean | AbstractListenerWebSocketSession.WebSocketSendProcessor.isDataEmpty(WebSocketMessage message) |
protected boolean | UndertowWebSocketSession.sendMessage(WebSocketMessage message) |
protected abstract boolean | AbstractListenerWebSocketSession.sendMessage(WebSocketMessage message) 指定された WebSocket メッセージを送信します。 |
protected boolean | JettyWebSocketSession.sendMessage(WebSocketMessage message) |
protected boolean | StandardWebSocketSession.sendMessage(WebSocketMessage message) |
protected io.netty.handler.codec.http.websocketx.WebSocketFrame | NettyWebSocketSessionSupport.toFrame(WebSocketMessage message) |
protected boolean | AbstractListenerWebSocketSession.WebSocketSendProcessor.write(WebSocketMessage message) |
修飾子と型 | メソッドと説明 |
---|---|
abstract reactor.core.publisher.Mono<VoidSE> | AbstractWebSocketSession.send(Publisher<WebSocketMessage> messages) |
reactor.core.publisher.Mono<VoidSE> | AbstractListenerWebSocketSession.send(Publisher<WebSocketMessage> messages) |
reactor.core.publisher.Mono<VoidSE> | ReactorNettyWebSocketSession.send(Publisher<WebSocketMessage> messages) |