@Test public void writeUnknownFrame() { childChannelInitializer.handler = new ChannelInboundHandlerAdapter() { @Override public void channelActive(ChannelHandlerContext ctx) { ctx.writeAndFlush(new DefaultHttp2HeadersFrame(new DefaultHttp2Headers())); ctx.writeAndFlush(new DefaultHttp2UnknownFrame((byte) 99, new Http2Flags())); ctx.fireChannelActive(); } }; Channel childChannel = newOutboundStream(); assertTrue(childChannel.isActive()); Http2FrameStream stream = readOutboundHeadersAndAssignId(); parentChannel.runPendingTasks(); Http2UnknownFrame frame = parentChannel.readOutbound(); assertEquals(stream, frame.stream()); assertEquals(99, frame.frameType()); assertEquals(new Http2Flags(), frame.flags()); frame.release(); }
final Http2StreamChannel newOutboundStream() { return new DefaultHttp2StreamChannel(newStream(), true); }
Http2MultiplexCodec extends Http2FrameCodec { final Http2StreamChannel newOutboundStream() { return new DefaultHttp2StreamChannel(newStream(), true); } }
Http2MultiplexCodec extends Http2FrameCodec { final Http2StreamChannel newOutboundStream() { return new DefaultHttp2StreamChannel(newStream(), true); } Http2MultiplexCodec(Http2ConnectionEncoder encoder,
                        Http2ConnectionDecoder decoder,
                        Http2Settings initialSettings,
                        ChannelHandler inboundStreamHandler); }
Http2MultiplexCodec extends Http2FrameCodec { final Http2StreamChannel newOutboundStream() { return new DefaultHttp2StreamChannel(newStream(), true); } Http2MultiplexCodec(Http2ConnectionEncoder encoder,
                        Http2ConnectionDecoder decoder,
                        Http2Settings initialSettings,
                        ChannelHandler inboundStreamHandler); @Override final void handlerAdded0(ChannelHandlerContext ctx); @Override final void handlerRemoved0(ChannelHandlerContext ctx); @Override final void channelReadComplete(ChannelHandlerContext ctx); @Override final void channelRead(ChannelHandlerContext ctx, Object msg); }
Http2MultiplexCodec extends Http2FrameCodec { final Http2StreamChannel newOutboundStream() { return new DefaultHttp2StreamChannel(newStream(), true); } Http2MultiplexCodec(Http2ConnectionEncoder encoder,
                        Http2ConnectionDecoder decoder,
                        Http2Settings initialSettings,
                        ChannelHandler inboundStreamHandler); @Override final void handlerAdded0(ChannelHandlerContext ctx); @Override final void handlerRemoved0(ChannelHandlerContext ctx); @Override final void channelReadComplete(ChannelHandlerContext ctx); @Override final void channelRead(ChannelHandlerContext ctx, Object msg);  }