| Package | Description | 
|---|---|
| org.springframework.web.reactive.socket | 
 Abstractions and support classes for reactive WebSocket interactions. 
 | 
| org.springframework.web.reactive.socket.adapter | 
 Classes adapting Spring's Reactive WebSocket API to and from WebSocket runtimes. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
WebSocketMessage | 
WebSocketSession.binaryMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)
Factory method to create a binary WebSocketMessage using the
  
WebSocketSession.bufferFactory() for the session. | 
WebSocketMessage | 
WebSocketSession.pingMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)
Factory method to create a ping WebSocketMessage using the
  
WebSocketSession.bufferFactory() for the session. | 
WebSocketMessage | 
WebSocketSession.pongMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)
Factory method to create a pong WebSocketMessage using the
  
WebSocketSession.bufferFactory() for the session. | 
WebSocketMessage | 
WebSocketMessage.retain()
Retain the data buffer for the message payload, which is useful on
 runtimes (e.g. 
 | 
WebSocketMessage | 
WebSocketSession.textMessage(String payload)
Factory method to create a text  
WebSocketMessage using the
 WebSocketSession.bufferFactory() for the session. | 
| Modifier and Type | Method and Description | 
|---|---|
reactor.core.publisher.Flux<WebSocketMessage> | 
WebSocketSession.receive()
Provides access to the stream of inbound messages. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
reactor.core.publisher.Mono<Void> | 
WebSocketSession.send(Publisher<WebSocketMessage> messages)
Give a source of outgoing messages, write the messages and return a
  
Mono<Void> that completes when the source completes and writing
 is done. | 
| Modifier and Type | Method and Description | 
|---|---|
WebSocketMessage | 
AbstractWebSocketSession.binaryMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)  | 
WebSocketMessage | 
AbstractWebSocketSession.pingMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)  | 
WebSocketMessage | 
AbstractWebSocketSession.pongMessage(Function<DataBufferFactory,DataBuffer> payloadFactory)  | 
WebSocketMessage | 
AbstractWebSocketSession.textMessage(String payload)  | 
protected WebSocketMessage | 
NettyWebSocketSessionSupport.toMessage(io.netty.handler.codec.http.websocketx.WebSocketFrame frame)  | 
| Modifier and Type | Method and Description | 
|---|---|
abstract reactor.core.publisher.Flux<WebSocketMessage> | 
AbstractWebSocketSession.receive()  | 
reactor.core.publisher.Flux<WebSocketMessage> | 
AbstractListenerWebSocketSession.receive()  | 
reactor.core.publisher.Flux<WebSocketMessage> | 
ReactorNettyWebSocketSession.receive()  | 
| Modifier and Type | Method and Description | 
|---|---|
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)
Send the given WebSocket message. 
 | 
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)  | 
| Modifier and Type | Method and Description | 
|---|---|
abstract reactor.core.publisher.Mono<Void> | 
AbstractWebSocketSession.send(Publisher<WebSocketMessage> messages)  | 
reactor.core.publisher.Mono<Void> | 
AbstractListenerWebSocketSession.send(Publisher<WebSocketMessage> messages)  | 
reactor.core.publisher.Mono<Void> | 
ReactorNettyWebSocketSession.send(Publisher<WebSocketMessage> messages)  |