spring-framework / org.springframework.web.reactive.socket.adapter / NettyWebSocketSessionSupport

NettyWebSocketSessionSupport

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

Functions

bufferFactory

open fun bufferFactory(): NettyDataBufferFactory

Inherited Functions

binaryMessage

open fun binaryMessage(payloadFactory: Function<DataBufferFactory, DataBuffer>): WebSocketMessage

getHandshakeInfo

open fun getHandshakeInfo(): HandshakeInfo

getId

open fun getId(): String

pingMessage

open fun pingMessage(payloadFactory: Function<DataBufferFactory, DataBuffer>): WebSocketMessage

pongMessage

open fun pongMessage(payloadFactory: Function<DataBufferFactory, DataBuffer>): WebSocketMessage

receive

abstract fun receive(): Flux<WebSocketMessage>

send

abstract fun send(messages: Publisher<WebSocketMessage>): Mono<Void>

textMessage

open fun textMessage(payload: String): WebSocketMessage

toString

open fun toString(): String

Inheritors

ReactorNettyWebSocketSession

open class ReactorNettyWebSocketSession : NettyWebSocketSessionSupport<WebSocketConnection>

Spring WebSocketSession implementation that adapts to Reactor Netty's WebSocket NettyInbound and NettyOutbound.