@Test public void streamShouldBeOpenInListener() { final Http2FrameStream stream2 = frameCodec.newStream(); assertEquals(State.IDLE, stream2.state()); final AtomicBoolean listenerExecuted = new AtomicBoolean(); channel.writeAndFlush(new DefaultHttp2HeadersFrame(new DefaultHttp2Headers()).stream(stream2)) .addListener(new ChannelFutureListener() { @Override public void operationComplete(ChannelFuture future) throws Exception { assertTrue(future.isSuccess()); assertEquals(State.OPEN, stream2.state()); listenerExecuted.set(true); } }); assertTrue(listenerExecuted.get()); }
DefaultHttp2FrameStream newStream() { return new DefaultHttp2FrameStream(); }
Http2FrameCodec extends Http2ConnectionHandler { DefaultHttp2FrameStream newStream() { return new DefaultHttp2FrameStream(); } }
Http2FrameCodec extends Http2ConnectionHandler { DefaultHttp2FrameStream newStream() { return new DefaultHttp2FrameStream(); } Http2FrameCodec(Http2ConnectionEncoder encoder, Http2ConnectionDecoder decoder, Http2Settings initialSettings); }
Http2FrameCodec extends Http2ConnectionHandler { DefaultHttp2FrameStream newStream() { return new DefaultHttp2FrameStream(); } Http2FrameCodec(Http2ConnectionEncoder encoder, Http2ConnectionDecoder decoder, Http2Settings initialSettings); @Override final void handlerAdded(ChannelHandlerContext ctx); @Override final void userEventTriggered(ChannelHandlerContext ctx, Object evt); @Override void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise); }
Http2FrameCodec extends Http2ConnectionHandler { DefaultHttp2FrameStream newStream() { return new DefaultHttp2FrameStream(); } Http2FrameCodec(Http2ConnectionEncoder encoder, Http2ConnectionDecoder decoder, Http2Settings initialSettings); @Override final void handlerAdded(ChannelHandlerContext ctx); @Override final void userEventTriggered(ChannelHandlerContext ctx, Object evt); @Override void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise);  }