public interface WebsocketInbound extends NettyInbound
Modifier and Type | Method and Description |
---|---|
default WebsocketInbound |
aggregateFrames()
Turn this
WebsocketInbound into aggregating mode which will only produce
fully formed frame that have been received fragmented. |
default WebsocketInbound |
aggregateFrames(int maxContentLength)
Turn this
WebsocketInbound into aggregating mode which will only produce
fully formed frame that have been received fragmented. |
HttpHeaders |
headers()
Returns the websocket remote headers sent during handshake
|
Mono<WebSocketCloseStatus> |
receiveCloseStatus()
Receive the close status code and reason if sent by the remote peer,
or empty if the connection completes otherwise.
|
default Flux<WebSocketFrame> |
receiveFrames()
Receive a
Flux of WebSocketFrame formed frame content. |
String |
selectedSubprotocol()
Returns the websocket subprotocol negotiated by the client and server during
the websocket handshake, or null if none was requested.
|
receive, receiveObject, withConnection
@Nullable String selectedSubprotocol()
HttpHeaders headers()
Mono<WebSocketCloseStatus> receiveCloseStatus()
default WebsocketInbound aggregateFrames()
WebsocketInbound
into aggregating mode which will only produce
fully formed frame that have been received fragmented.
Will aggregate up to 65,536 bytes per framedefault WebsocketInbound aggregateFrames(int maxContentLength)
WebsocketInbound
into aggregating mode which will only produce
fully formed frame that have been received fragmented.maxContentLength
- the maximum frame lengthdefault Flux<WebSocketFrame> receiveFrames()
Flux
of WebSocketFrame
formed frame content.Flux
of WebSocketFrame
formed frame content