| 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  WebSocketMessageusing theWebSocketSession.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) |