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.
|
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.upgrade |
Holds implementations of
RequestUpgradeStrategy . |
Modifier and Type | Method and Description |
---|---|
HandshakeInfo |
WebSocketSession.getHandshakeInfo()
Return information from the handshake request.
|
Modifier and Type | Method and Description |
---|---|
HandshakeInfo |
AbstractWebSocketSession.getHandshakeInfo() |
Constructor and Description |
---|
AbstractListenerWebSocketSession(T delegate,
String id,
HandshakeInfo handshakeInfo,
DataBufferFactory bufferFactory)
Base constructor.
|
AbstractListenerWebSocketSession(T delegate,
String id,
HandshakeInfo info,
DataBufferFactory bufferFactory,
reactor.core.publisher.MonoProcessor<Void> completionMono)
Alternative constructor with completion
Mono<Void> to propagate
the session completion (success or error) (for client-side use). |
AbstractWebSocketSession(T delegate,
String id,
HandshakeInfo info,
DataBufferFactory bufferFactory)
Create a new WebSocket session.
|
JettyWebSocketSession(org.eclipse.jetty.websocket.api.Session session,
HandshakeInfo info,
DataBufferFactory factory) |
JettyWebSocketSession(org.eclipse.jetty.websocket.api.Session session,
HandshakeInfo info,
DataBufferFactory factory,
reactor.core.publisher.MonoProcessor<Void> completionMono) |
NettyWebSocketSessionSupport(T delegate,
HandshakeInfo info,
NettyDataBufferFactory factory) |
ReactorNettyWebSocketSession(reactor.netty.http.websocket.WebsocketInbound inbound,
reactor.netty.http.websocket.WebsocketOutbound outbound,
HandshakeInfo info,
NettyDataBufferFactory bufferFactory)
Constructor for the session, using the
NettyWebSocketSessionSupport.DEFAULT_FRAME_MAX_SIZE value. |
ReactorNettyWebSocketSession(reactor.netty.http.websocket.WebsocketInbound inbound,
reactor.netty.http.websocket.WebsocketOutbound outbound,
HandshakeInfo info,
NettyDataBufferFactory bufferFactory,
int maxFramePayloadLength)
Constructor with an additional maxFramePayloadLength argument.
|
StandardWebSocketSession(Session session,
HandshakeInfo info,
DataBufferFactory factory) |
StandardWebSocketSession(Session session,
HandshakeInfo info,
DataBufferFactory factory,
reactor.core.publisher.MonoProcessor<Void> completionMono) |
TomcatWebSocketSession(Session session,
HandshakeInfo info,
DataBufferFactory factory) |
TomcatWebSocketSession(Session session,
HandshakeInfo info,
DataBufferFactory factory,
reactor.core.publisher.MonoProcessor<Void> completionMono) |
UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel,
HandshakeInfo info,
DataBufferFactory factory) |
UndertowWebSocketSession(io.undertow.websockets.core.WebSocketChannel channel,
HandshakeInfo info,
DataBufferFactory factory,
reactor.core.publisher.MonoProcessor<Void> completionMono) |
Modifier and Type | Method and Description |
---|---|
protected StandardWebSocketSession |
StandardWebSocketClient.createWebSocketSession(Session session,
HandshakeInfo info,
reactor.core.publisher.MonoProcessor<Void> completion) |
protected StandardWebSocketSession |
TomcatWebSocketClient.createWebSocketSession(Session session,
HandshakeInfo info,
reactor.core.publisher.MonoProcessor<Void> completion) |
Modifier and Type | Method and Description |
---|---|
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> |
TomcatRequestUpgradeStrategy.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> |
JettyRequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler handler,
String subProtocol,
Supplier<HandshakeInfo> handshakeInfoFactory) |
reactor.core.publisher.Mono<Void> |
UndertowRequestUpgradeStrategy.upgrade(ServerWebExchange exchange,
WebSocketHandler handler,
String subProtocol,
Supplier<HandshakeInfo> handshakeInfoFactory) |