Package | Description |
---|---|
org.springframework.web.reactive.socket.adapter |
Classes adapting Spring's Reactive WebSocket API to and from WebSocket runtimes.
|
org.springframework.web.reactive.socket.client |
Client support for WebSocket interactions.
|
org.springframework.web.reactive.socket.server |
Server support for WebSocket interactions.
|
org.springframework.web.reactive.socket.server.support |
Server-side support classes for WebSocket requests.
|
org.springframework.web.reactive.socket.server.upgrade |
Holds implementations of
RequestUpgradeStrategy . |
Modifier and Type | Class and Description |
---|---|
class |
ContextWebSocketHandler
WebSocketHandler decorator that enriches the context of the target handler. |
Modifier and Type | Method and Description |
---|---|
static WebSocketHandler |
ContextWebSocketHandler.decorate(WebSocketHandler handler,
reactor.util.context.ContextView contextView)
Return the given handler, decorated to insert the given context, or the
same handler instance when the context is empty.
|
Modifier and Type | Method and Description |
---|---|
static WebSocketHandler |
ContextWebSocketHandler.decorate(WebSocketHandler handler,
reactor.util.context.ContextView contextView)
Return the given handler, decorated to insert the given context, or the
same handler instance when the context is empty.
|
Constructor and Description |
---|
JettyWebSocketHandlerAdapter(WebSocketHandler handler,
Function<org.eclipse.jetty.websocket.api.Session,JettyWebSocketSession> sessionFactory) |
StandardWebSocketHandlerAdapter(WebSocketHandler handler,
Function<Session,StandardWebSocketSession> sessionFactory) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Void> |
WebSocketClient.execute(URI url,
HttpHeaders headers,
WebSocketHandler handler)
A variant of
WebSocketClient.execute(URI, WebSocketHandler) with custom headers. |
reactor.core.publisher.Mono<Void> |
JettyWebSocketClient.execute(URI url,
HttpHeaders headers,
WebSocketHandler handler) |
reactor.core.publisher.Mono<Void> |
StandardWebSocketClient.execute(URI url,
HttpHeaders headers,
WebSocketHandler handler) |
reactor.core.publisher.Mono<Void> |
UndertowWebSocketClient.execute(URI url,
HttpHeaders headers,
WebSocketHandler handler) |
reactor.core.publisher.Mono<Void> |
ReactorNettyWebSocketClient.execute(URI url,
HttpHeaders requestHeaders,
WebSocketHandler handler) |
reactor.core.publisher.Mono<Void> |
WebSocketClient.execute(URI url,
WebSocketHandler handler)
Execute a handshake request to the given url and handle the resulting
WebSocket session with the given handler.
|
reactor.core.publisher.Mono<Void> |
JettyWebSocketClient.execute(URI url,
WebSocketHandler handler) |
reactor.core.publisher.Mono<Void> |
StandardWebSocketClient.execute(URI url,
WebSocketHandler handler) |
reactor.core.publisher.Mono<Void> |
UndertowWebSocketClient.execute(URI url,
WebSocketHandler handler) |
reactor.core.publisher.Mono<Void> |
ReactorNettyWebSocketClient.execute(URI url,
WebSocketHandler handler) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Void> |
WebSocketService.handleRequest(ServerWebExchange exchange,
WebSocketHandler webSocketHandler)
Handle the request with the given
WebSocketHandler . |
default reactor.core.publisher.Mono<Void> |
RequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler webSocketHandler,
String subProtocol)
Deprecated.
as of 5.1 in favor of
RequestUpgradeStrategy.upgrade(ServerWebExchange, WebSocketHandler, String, Supplier) |
default reactor.core.publisher.Mono<Void> |
RequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler webSocketHandler,
String subProtocol,
Supplier<HandshakeInfo> handshakeInfoFactory)
Upgrade to a WebSocket session and handle it with the given handler.
|
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Void> |
HandshakeWebSocketService.handleRequest(ServerWebExchange exchange,
WebSocketHandler handler) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Void> |
UndertowRequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler handler,
String subProtocol,
Supplier<HandshakeInfo> handshakeInfoFactory) |
reactor.core.publisher.Mono<Void> |
JettyRequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler handler,
String subProtocol,
Supplier<HandshakeInfo> handshakeInfoFactory) |
reactor.core.publisher.Mono<Void> |
ReactorNettyRequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler handler,
String subProtocol,
Supplier<HandshakeInfo> handshakeInfoFactory) |
reactor.core.publisher.Mono<Void> |
TomcatRequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler handler,
String subProtocol,
Supplier<HandshakeInfo> handshakeInfoFactory) |