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 . |
Constructor and Description |
---|
JettyWebSocketHandlerAdapter(WebSocketHandler handler,
java.util.function.Function<org.eclipse.jetty.websocket.api.Session,JettyWebSocketSession> sessionFactory) |
StandardWebSocketHandlerAdapter(WebSocketHandler handler,
java.util.function.Function<javax.websocket.Session,StandardWebSocketSession> sessionFactory) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<java.lang.Void> |
UndertowWebSocketClient.execute(java.net.URI url,
HttpHeaders headers,
WebSocketHandler handler) |
reactor.core.publisher.Mono<java.lang.Void> |
ReactorNettyWebSocketClient.execute(java.net.URI url,
HttpHeaders requestHeaders,
WebSocketHandler handler) |
reactor.core.publisher.Mono<java.lang.Void> |
StandardWebSocketClient.execute(java.net.URI url,
HttpHeaders headers,
WebSocketHandler handler) |
reactor.core.publisher.Mono<java.lang.Void> |
WebSocketClient.execute(java.net.URI url,
HttpHeaders headers,
WebSocketHandler handler)
A variant of
WebSocketClient.execute(URI, WebSocketHandler) with custom headers. |
reactor.core.publisher.Mono<java.lang.Void> |
JettyWebSocketClient.execute(java.net.URI url,
HttpHeaders headers,
WebSocketHandler handler) |
reactor.core.publisher.Mono<java.lang.Void> |
UndertowWebSocketClient.execute(java.net.URI url,
WebSocketHandler handler) |
reactor.core.publisher.Mono<java.lang.Void> |
ReactorNettyWebSocketClient.execute(java.net.URI url,
WebSocketHandler handler) |
reactor.core.publisher.Mono<java.lang.Void> |
StandardWebSocketClient.execute(java.net.URI url,
WebSocketHandler handler) |
reactor.core.publisher.Mono<java.lang.Void> |
WebSocketClient.execute(java.net.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<java.lang.Void> |
JettyWebSocketClient.execute(java.net.URI url,
WebSocketHandler handler) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<java.lang.Void> |
WebSocketService.handleRequest(ServerWebExchange exchange,
WebSocketHandler webSocketHandler)
Handle the request with the given
WebSocketHandler . |
default reactor.core.publisher.Mono<java.lang.Void> |
RequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler webSocketHandler,
java.lang.String subProtocol)
Deprecated.
as of 5.1 in favor of
RequestUpgradeStrategy.upgrade(ServerWebExchange, WebSocketHandler, String, Supplier) |
default reactor.core.publisher.Mono<java.lang.Void> |
RequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler webSocketHandler,
java.lang.String subProtocol,
java.util.function.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<java.lang.Void> |
HandshakeWebSocketService.handleRequest(ServerWebExchange exchange,
WebSocketHandler handler) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<java.lang.Void> |
ReactorNettyRequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler handler,
java.lang.String subProtocol,
java.util.function.Supplier<HandshakeInfo> handshakeInfoFactory) |
reactor.core.publisher.Mono<java.lang.Void> |
JettyRequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler handler,
java.lang.String subProtocol,
java.util.function.Supplier<HandshakeInfo> handshakeInfoFactory) |
reactor.core.publisher.Mono<java.lang.Void> |
TomcatRequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler handler,
java.lang.String subProtocol,
java.util.function.Supplier<HandshakeInfo> handshakeInfoFactory) |
reactor.core.publisher.Mono<java.lang.Void> |
UndertowRequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler handler,
java.lang.String subProtocol,
java.util.function.Supplier<HandshakeInfo> handshakeInfoFactory) |