reactor.netty.http.websocket

Interface WebsocketInbound

All Superinterfaces:

NettyInbound

public interface WebsocketInbound
extends NettyInbound

A websocket framed inbound

Since:

0.6

Author:

Stephane Maldini, Simon Baslé

Method Summary

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
default Flux<WebSocketFrame>	receiveFrames()
String	selectedSubprotocol() Returns the websocket subprotocol negotiated by the client and server during the websocket handshake, or null if none was requested.

Methods inherited from interface reactor.netty.NettyInbound

receive, receiveObject, withConnection

Method Detail

selectedSubprotocol

@Nullable
String selectedSubprotocol()

Returns the websocket subprotocol negotiated by the client and server during the websocket handshake, or null if none was requested.

Returns:

the subprotocol, or null

headers

HttpHeaders headers()

Returns the websocket remote headers sent during handshake

Returns:

the websocket remote headers sent during handshake

aggregateFrames

default WebsocketInbound aggregateFrames()

Turn this WebsocketInbound into aggregating mode which will only produce fully formed frame that have been received fragmented. Will aggregate up to 65,536 bytes per frame

Returns:

this inbound

aggregateFrames

default WebsocketInbound aggregateFrames(int maxContentLength)

Turn this WebsocketInbound into aggregating mode which will only produce fully formed frame that have been received fragmented.

Parameters:

maxContentLength - the maximum frame length

Returns:

this inbound

receiveFrames

default Flux<WebSocketFrame> receiveFrames()

Returns:

a Flux of WebSocketFrame formed frame content