public class ReactorNettyRequestUpgradeStrategy extends java.lang.Object implements RequestUpgradeStrategy
RequestUpgradeStrategy for use with Reactor Netty.| Constructor and Description |
|---|
ReactorNettyRequestUpgradeStrategy() |
| Modifier and Type | Method and Description |
|---|---|
reactor.core.publisher.Mono<java.lang.Void> |
upgrade(ServerWebExchange exchange,
WebSocketHandler handler,
java.lang.String subProtocol)
Upgrade to a WebSocket session and handle it with the given handler.
|
public reactor.core.publisher.Mono<java.lang.Void> upgrade(ServerWebExchange exchange, WebSocketHandler handler, @Nullable java.lang.String subProtocol)
RequestUpgradeStrategyupgrade in interface RequestUpgradeStrategyexchange - the current exchangehandler - handler for the WebSocket sessionsubProtocol - the selected sub-protocol got the handlerMono<Void> to indicate the outcome of the
WebSocket session handling.