abstract class NettyWebSocketSessionSupport<T : Any> : AbstractWebSocketSession<T>
Base class for Netty-based WebSocketSession adapters that provides convenience methods to convert Netty WebSocketFrames to and from WebSocketMessages.
Author
Rossen Stoyanchev
Since
5.0
open fun bufferFactory(): NettyDataBufferFactory |
open fun binaryMessage(payloadFactory: Function<DataBufferFactory, DataBuffer>): WebSocketMessage |
|
open fun getHandshakeInfo(): HandshakeInfo |
|
open fun getId(): String |
|
open fun pingMessage(payloadFactory: Function<DataBufferFactory, DataBuffer>): WebSocketMessage |
|
open fun pongMessage(payloadFactory: Function<DataBufferFactory, DataBuffer>): WebSocketMessage |
|
abstract fun receive(): Flux<WebSocketMessage> |
|
abstract fun send(messages: Publisher<WebSocketMessage>): Mono<Void> |
|
open fun textMessage(payload: String): WebSocketMessage |
|
open fun toString(): String |
open class ReactorNettyWebSocketSession : NettyWebSocketSessionSupport<WebSocketConnection>
Spring WebSocketSession implementation that adapts to Reactor Netty's WebSocket NettyInbound and NettyOutbound. |