NettyPipeline.java 文件源码

/**
 * Create a new {@link ChannelInboundHandler} that will invoke
 * {@link BiConsumer#accept} on
 * {@link ChannelInboundHandler#channelRead(ChannelHandlerContext, Object)}.
 *
 * @param handler the channel-read callback
 *
 * @return a marking event used when a netty connector handler terminates
 */
static ChannelInboundHandler inboundHandler(BiConsumer<? super ChannelHandlerContext, Object> handler) {
    return new ReactorNetty.ExtractorHandler(handler);
}