public class NettyHttpWSServerHandler<IN,OUT> extends NettyHttpServerHandler<IN,OUT>
NettyHttpChannel
and Buffer
).NettyChannelHandlerBridge.ChannelInputSubscriberEvent<IN>
request
CHANNEL_REF, channelStream, channelSubscription, handler, log
Constructor and Description |
---|
NettyHttpWSServerHandler(String wsUrl,
String protocols,
NettyHttpServerHandler<IN,OUT> originalHandler) |
Modifier and Type | Method and Description |
---|---|
void |
channelRead(io.netty.channel.ChannelHandlerContext ctx,
Object frame) |
protected io.netty.channel.ChannelFuture |
doOnWrite(Object data,
io.netty.channel.ChannelHandlerContext ctx) |
protected void |
writeLast(io.netty.channel.ChannelHandlerContext ctx) |
channelActive, doOnSubscribe, postRead
channelInactive, channelReadComplete, convertBufferToByteBuff, doOnTerminate, doRead, exceptionCaught, getChannelStream, getHandler, subscription, userEventTriggered, write
bind, close, connect, deregister, disconnect, flush, read
channelRegistered, channelUnregistered, channelWritabilityChanged
handlerAdded, handlerRemoved, isSharable
public NettyHttpWSServerHandler(String wsUrl, String protocols, NettyHttpServerHandler<IN,OUT> originalHandler)
public void channelRead(io.netty.channel.ChannelHandlerContext ctx, Object frame) throws Exception
channelRead
in interface io.netty.channel.ChannelInboundHandler
channelRead
in class NettyHttpServerHandler<IN,OUT>
Exception
protected void writeLast(io.netty.channel.ChannelHandlerContext ctx)
writeLast
in class NettyHttpServerHandler<IN,OUT>
protected io.netty.channel.ChannelFuture doOnWrite(Object data, io.netty.channel.ChannelHandlerContext ctx)
doOnWrite
in class NettyHttpServerHandler<IN,OUT>
Copyright © 2016. All rights reserved.