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

ReactorNettyWebSocketSession

open class ReactorNettyWebSocketSession : NettyWebSocketSessionSupport<WebSocketConnection>

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

Author
Rossen Stoyanchev

Since
5.0

Constructors

<init>

 ReactorNettyWebSocketSession(inbound: WebsocketInbound, outbound: WebsocketOutbound, info: HandshakeInfo, bufferFactory: NettyDataBufferFactory)

Functions

close

 open fun close(status: CloseStatus): Mono<Void>

receive

 open fun receive(): Flux<WebSocketMessage>

send

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

Inherited Functions

bufferFactory

 open fun bufferFactory(): NettyDataBufferFactory