下面列出了怎么用io.netty.channel.ChannelOutboundHandler的API类实例代码及写法,或者点击链接到github查看源代码。
public void addChannelOutboundHandler(ChannelOutboundHandler channelOutboundHandler) {
channelOutboundHandlerList.add(channelOutboundHandler);
}
public List<ChannelOutboundHandler> getChannelOutboundHandlerList() {
return channelOutboundHandlerList;
}
public void addHttpResponseHandler(ChannelOutboundHandler channelOutboundHandler) {
httpResponseHandlerList.add(channelOutboundHandler);
}
public List<ChannelOutboundHandler> getHttpResponseHandlerList() {
return httpResponseHandlerList;
}
public RsfDuplexHandler(ChannelInboundHandler inBoundArray, ChannelOutboundHandler outBoundArray) {
super(inBoundArray, outBoundArray);
}
/**
* Add a {@link ChannelHandler} with {@link #addHandlerFirst} if of type of
* {@link io.netty.channel.ChannelOutboundHandler} otherwise with
* {@link #addHandlerLast}. Implementation may add more auto handling in particular
* HTTP based context will prepend an HttpContent body extractor.
* <p>
* {@code [ [reactor codecs], [<- user FIRST HANDLERS added here, user LAST HANDLERS added here ->], [reactor handlers] ]}
* <p>
* If effectively added, the handler will be safely removed when the channel is made
* inactive (pool release).
* As the Connection object is available once the channel is in active state, events prior this state
* will not be available (i.e. {@code channelRegistered}, {@code initChannel}, {@code channelActive}, etc.)
*
* @param name handler name
* @param handler handler instance
*
* @return this Connection
*/
default Connection addHandler(String name, ChannelHandler handler){
if(handler instanceof ChannelOutboundHandler){
addHandlerFirst(name, handler);
}
else {
addHandlerLast(name, handler);
}
return this;
}