Top Inners Fields Constructors Methods
io.rsocket.transport.netty.server

pack-priv abstract Class BaseWebsocketServerTransport<SELF extends io.rsocket.transport.netty.server.BaseWebsocketServerTransport<SELF, T>, T extends io.rsocket.Closeable>

extends Object
implements ServerTransport<T extends Closeable>
Class Inheritance
All Implemented Interfaces
io.rsocket.transport.ServerTransport, io.rsocket.transport.Transport
Known Direct Subclasses
io.rsocket.transport.netty.server.WebsocketRouteTransport, io.rsocket.transport.netty.server.WebsocketServerTransport
Static Imports
io.netty.channel.ChannelHandler.*, io.rsocket.frame.FrameLengthCodec.FRAME_LENGTH_MASK

Nested and Inner Type Summary

Modifier and TypeClass and Description
private static class
BaseWebsocketServerTransport.PongHandler

Field Summary

Modifier and TypeField and Description
private static final Logger
logger

private static final ChannelHandler
pongHandler

pack-priv static Function<HttpServer, HttpServer>
serverConfigurer

pack-priv final WebsocketServerSpec.Builder
specBuilder

Constructor Summary

AccessConstructor and Description
pack-priv
BaseWebsocketServerTransport()

Method Summary

Modifier and TypeMethod and Description
public int
maxFrameLength()

Overrides default io.rsocket.transport.Transport.maxFrameLength.

Configurations that exposes the maximum frame size that a DuplexConnection can bring up to RSocket level.
public SELF

Returns:

the same instance for method chaining
webSocketSpec(Consumer<WebsocketServerSpec.Builder>
the configurer to apply to the spec
configurer)

Provide a consumer to customize properties of the WebsocketServerSpec to use for WebSocket upgrades.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

loggerback to summary
private static final Logger logger
pongHandlerback to summary
private static final ChannelHandler pongHandler
serverConfigurerback to summary
pack-priv static Function<HttpServer, HttpServer> serverConfigurer
specBuilderback to summary
pack-priv final WebsocketServerSpec.Builder specBuilder

Constructor Detail

BaseWebsocketServerTransportback to summary
pack-priv BaseWebsocketServerTransport()

Method Detail

maxFrameLengthback to summary
public int maxFrameLength()

Overrides default io.rsocket.transport.Transport.maxFrameLength.

Doc from io.rsocket.transport.Transport.maxFrameLength.

Configurations that exposes the maximum frame size that a DuplexConnection can bring up to RSocket level.

This number should not exist the 16,777,215 (maximum frame size specified by RSocket spec)

Returns:int

return maximum configured frame size limit

Annotations
@Override
webSocketSpecback to summary
public SELF webSocketSpec(Consumer<WebsocketServerSpec.Builder> configurer)

Provide a consumer to customize properties of the WebsocketServerSpec to use for WebSocket upgrades. The consumer is invoked immediately.

Parameters
configurer:Consumer<WebsocketServerSpec.Builder>

the configurer to apply to the spec

Returns:SELF

the same instance for method chaining

Annotations
@SuppressWarnings:unchecked
Since
1.0.1
io.rsocket.transport.netty.server back to summary

private Class BaseWebsocketServerTransport.PongHandler

extends ChannelInboundHandlerAdapter
Class Inheritance
Annotations
@Sharable

Constructor Summary

AccessConstructor and Description
private
PongHandler()

Method Summary

Modifier and TypeMethod and Description
public void
channelRead(ChannelHandlerContext ctx, Object msg)

Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

Implements io.netty.channel.ChannelInboundHandler.channelRead.

Calls ChannelHandlerContext#fireChannelRead(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline.
Inherited from io.netty.channel.ChannelInboundHandlerAdapter:
channelActivechannelInactivechannelReadCompletechannelRegisteredchannelUnregisteredchannelWritabilityChangedexceptionCaughtuserEventTriggered

Constructor Detail

PongHandlerback to summary
private PongHandler()

Method Detail

channelReadback to summary
public void channelRead(ChannelHandlerContext ctx, Object msg)

Overrides io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

Implements io.netty.channel.ChannelInboundHandler.channelRead.

Doc from io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

Calls ChannelHandlerContext#fireChannelRead(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

Annotations
@Override