@Test public void streamIdentifiersExhausted() throws Http2Exception { int maxServerStreamId = Integer.MAX_VALUE - 1; assertNotNull(frameCodec.connection().local().createStream(maxServerStreamId, false)); Http2FrameStream stream = frameCodec.newStream(); assertNotNull(stream); ChannelPromise writePromise = channel.newPromise(); channel.writeAndFlush(new DefaultHttp2HeadersFrame(new DefaultHttp2Headers()).stream(stream), writePromise); assertThat(writePromise.cause(), instanceOf(Http2NoMoreStreamIdsException.class)); }
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);  }