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(org.reactivestreams.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 |
---|---|
reactor.core.publisher.Flux<WebSocketMessage> |
AbstractListenerWebSocketSession.receive() |
abstract reactor.core.publisher.Flux<WebSocketMessage> |
AbstractWebSocketSession.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 abstract boolean |
AbstractListenerWebSocketSession.sendMessage(WebSocketMessage message)
Send the given WebSocket message.
|
protected boolean |
StandardWebSocketSession.sendMessage(WebSocketMessage message) |
protected boolean |
UndertowWebSocketSession.sendMessage(WebSocketMessage message) |
protected boolean |
JettyWebSocketSession.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 |
---|---|
reactor.core.publisher.Mono<Void> |
AbstractListenerWebSocketSession.send(org.reactivestreams.Publisher<WebSocketMessage> messages) |
abstract reactor.core.publisher.Mono<Void> |
AbstractWebSocketSession.send(org.reactivestreams.Publisher<WebSocketMessage> messages) |
reactor.core.publisher.Mono<Void> |
ReactorNettyWebSocketSession.send(org.reactivestreams.Publisher<WebSocketMessage> messages) |