org.springframework.web.reactive.socket.server.upgrade

Class Jetty10RequestUpgradeStrategy

java.lang.Object

org.springframework.web.reactive.socket.server.upgrade.Jetty10RequestUpgradeStrategy

All Implemented Interfaces:

RequestUpgradeStrategy

public class Jetty10RequestUpgradeStrategy
extends Object
implements RequestUpgradeStrategy

A RequestUpgradeStrategy for use with Jetty 10.

Since:

5.3.4

Author:

Rossen Stoyanchev

Constructor Summary

Constructors

Constructor and Description
Jetty10RequestUpgradeStrategy()

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Mono<Void>	upgrade(ServerWebExchange exchange, WebSocketHandler handler, String subProtocol, Supplier<HandshakeInfo> handshakeInfoFactory) Upgrade to a WebSocket session and handle it with the given handler.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.web.reactive.socket.server.RequestUpgradeStrategy

upgrade

Constructor Detail

Jetty10RequestUpgradeStrategy

public Jetty10RequestUpgradeStrategy()

Method Detail

upgrade

public reactor.core.publisher.Mono<Void> upgrade(ServerWebExchange exchange,
                                                 WebSocketHandler handler,
                                                 @Nullable
                                                 String subProtocol,
                                                 Supplier<HandshakeInfo> handshakeInfoFactory)

Description copied from interface: RequestUpgradeStrategy

Upgrade to a WebSocket session and handle it with the given handler.

Specified by:

upgrade in interface RequestUpgradeStrategy

Parameters:

exchange - the current exchange

handler - handler for the WebSocket session

subProtocol - the selected sub-protocol got the handler

handshakeInfoFactory - factory to create HandshakeInfo for the WebSocket session

Returns:

completion Mono<Void> to indicate the outcome of the WebSocket session handling.