Uses of Class
org.springframework.web.reactive.socket.WebSocketMessage
Package
Description
Abstractions and support classes for reactive WebSocket interactions.
Classes adapting Spring's Reactive WebSocket API to and from WebSocket runtimes.
-
Uses of WebSocketMessage in org.springframework.web.reactive.socket
Modifier and TypeMethodDescriptionWebSocketSession.binaryMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) Factory method to create a binary WebSocketMessage using theWebSocketSession.bufferFactory()
for the session.WebSocketSession.pingMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) Factory method to create a ping WebSocketMessage using theWebSocketSession.bufferFactory()
for the session.WebSocketSession.pongMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) Factory method to create a pong WebSocketMessage using theWebSocketSession.bufferFactory()
for the session.WebSocketMessage.retain()
Retain the data buffer for the message payload, which is useful on runtimes (e.g.WebSocketSession.textMessage
(String payload) Factory method to create a textWebSocketMessage
using theWebSocketSession.bufferFactory()
for the session.Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<WebSocketMessage>
WebSocketSession.receive()
Provides access to the stream of inbound messages.Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<Void>
WebSocketSession.send
(Publisher<WebSocketMessage> messages) Give a source of outgoing messages, write the messages and return aMono<Void>
that completes when the source completes and writing is done. -
Uses of WebSocketMessage in org.springframework.web.reactive.socket.adapter
Modifier and TypeMethodDescriptionAbstractWebSocketSession.binaryMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) AbstractWebSocketSession.pingMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) AbstractWebSocketSession.pongMessage
(Function<DataBufferFactory, DataBuffer> payloadFactory) AbstractWebSocketSession.textMessage
(String payload) protected WebSocketMessage
Netty5WebSocketSessionSupport.toMessage
(io.netty5.handler.codec.http.websocketx.WebSocketFrame frame) protected WebSocketMessage
NettyWebSocketSessionSupport.toMessage
(io.netty.handler.codec.http.websocketx.WebSocketFrame frame) Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<WebSocketMessage>
AbstractListenerWebSocketSession.receive()
abstract reactor.core.publisher.Flux<WebSocketMessage>
AbstractWebSocketSession.receive()
reactor.core.publisher.Flux<WebSocketMessage>
ReactorNetty2WebSocketSession.receive()
reactor.core.publisher.Flux<WebSocketMessage>
ReactorNettyWebSocketSession.receive()
Modifier and TypeMethodDescriptionprotected void
AbstractListenerWebSocketSession.WebSocketSendProcessor.discardData
(WebSocketMessage message) protected boolean
AbstractListenerWebSocketSession.WebSocketSendProcessor.isDataEmpty
(WebSocketMessage message) protected abstract boolean
AbstractListenerWebSocketSession.sendMessage
(WebSocketMessage message) Send the given WebSocket message.protected boolean
JettyWebSocketSession.sendMessage
(WebSocketMessage message) protected boolean
StandardWebSocketSession.sendMessage
(WebSocketMessage message) protected boolean
UndertowWebSocketSession.sendMessage
(WebSocketMessage message) protected io.netty5.handler.codec.http.websocketx.WebSocketFrame
Netty5WebSocketSessionSupport.toFrame
(WebSocketMessage message) protected io.netty.handler.codec.http.websocketx.WebSocketFrame
NettyWebSocketSessionSupport.toFrame
(WebSocketMessage message) protected boolean
AbstractListenerWebSocketSession.WebSocketSendProcessor.write
(WebSocketMessage message) Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<Void>
AbstractListenerWebSocketSession.send
(Publisher<WebSocketMessage> messages) abstract reactor.core.publisher.Mono<Void>
AbstractWebSocketSession.send
(Publisher<WebSocketMessage> messages) reactor.core.publisher.Mono<Void>
ReactorNetty2WebSocketSession.send
(Publisher<WebSocketMessage> messages) reactor.core.publisher.Mono<Void>
ReactorNettyWebSocketSession.send
(Publisher<WebSocketMessage> messages)