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 (for example, Netty) with pooled buffers.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>
JettyWebSocketSession.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 reactor.core.publisher.Mono<Void>
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>
JettyWebSocketSession.send
(Publisher<WebSocketMessage> messages) reactor.core.publisher.Mono<Void>
ReactorNetty2WebSocketSession.send
(Publisher<WebSocketMessage> messages) reactor.core.publisher.Mono<Void>
ReactorNettyWebSocketSession.send
(Publisher<WebSocketMessage> messages)