@Test(expected = AssertionError.class) public void invalidChildStreamIdThrows() { controller.updateDependencyTree(-1, STREAM_D, DEFAULT_PRIORITY_WEIGHT, true); }
@Override public void updateDependencyTree(int childStreamId, int parentStreamId, short weight, boolean exclusive) { assert weight >= MIN_WEIGHT && weight <= MAX_WEIGHT : "Invalid weight"; assert childStreamId != parentStreamId : "A stream cannot depend on itself"; assert childStreamId > 0 && parentStreamId >= 0 : "childStreamId must be > 0. parentStreamId must be >= 0."; streamByteDistributor.updateDependencyTree(childStreamId, parentStreamId, weight, exclusive); }
DefaultHttp2RemoteFlowController implements Http2RemoteFlowController { @Override public void updateDependencyTree(int childStreamId, int parentStreamId, short weight, boolean exclusive) { assert weight >= MIN_WEIGHT && weight <= MAX_WEIGHT : "Invalid weight"; assert childStreamId != parentStreamId : "A stream cannot depend on itself"; assert childStreamId > 0 && parentStreamId >= 0 : "childStreamId must be > 0. parentStreamId must be >= 0."; streamByteDistributor.updateDependencyTree(childStreamId, parentStreamId, weight, exclusive); } }
DefaultHttp2RemoteFlowController implements Http2RemoteFlowController { @Override public void updateDependencyTree(int childStreamId, int parentStreamId, short weight, boolean exclusive) { assert weight >= MIN_WEIGHT && weight <= MAX_WEIGHT : "Invalid weight"; assert childStreamId != parentStreamId : "A stream cannot depend on itself"; assert childStreamId > 0 && parentStreamId >= 0 : "childStreamId must be > 0. parentStreamId must be >= 0."; streamByteDistributor.updateDependencyTree(childStreamId, parentStreamId, weight, exclusive); } DefaultHttp2RemoteFlowController(Http2Connection connection);  DefaultHttp2RemoteFlowController(Http2Connection connection,
                                            StreamByteDistributor streamByteDistributor);  DefaultHttp2RemoteFlowController(Http2Connection connection, final Listener listener);  DefaultHttp2RemoteFlowController(Http2Connection connection,
                                            StreamByteDistributor streamByteDistributor,
                                            final Listener listener); }
DefaultHttp2RemoteFlowController implements Http2RemoteFlowController { @Override public void updateDependencyTree(int childStreamId, int parentStreamId, short weight, boolean exclusive) { assert weight >= MIN_WEIGHT && weight <= MAX_WEIGHT : "Invalid weight"; assert childStreamId != parentStreamId : "A stream cannot depend on itself"; assert childStreamId > 0 && parentStreamId >= 0 : "childStreamId must be > 0. parentStreamId must be >= 0."; streamByteDistributor.updateDependencyTree(childStreamId, parentStreamId, weight, exclusive); } DefaultHttp2RemoteFlowController(Http2Connection connection);  DefaultHttp2RemoteFlowController(Http2Connection connection,
                                            StreamByteDistributor streamByteDistributor);  DefaultHttp2RemoteFlowController(Http2Connection connection, final Listener listener);  DefaultHttp2RemoteFlowController(Http2Connection connection,
                                            StreamByteDistributor streamByteDistributor,
                                            final Listener listener); @Override void channelHandlerContext(ChannelHandlerContext ctx); @Override ChannelHandlerContext channelHandlerContext(); @Override void initialWindowSize(int newWindowSize); @Override int initialWindowSize(); @Override int windowSize(Http2Stream stream); @Override boolean isWritable(Http2Stream stream); @Override void channelWritabilityChanged(); @Override void updateDependencyTree(int childStreamId, int parentStreamId, short weight, boolean exclusive); @Override void listener(Listener listener); @Override void incrementWindowSize(Http2Stream stream, int delta); @Override void addFlowControlled(Http2Stream stream, FlowControlled frame); @Override boolean hasFlowControlled(Http2Stream stream); @Override void writePendingBytes(); }
DefaultHttp2RemoteFlowController implements Http2RemoteFlowController { @Override public void updateDependencyTree(int childStreamId, int parentStreamId, short weight, boolean exclusive) { assert weight >= MIN_WEIGHT && weight <= MAX_WEIGHT : "Invalid weight"; assert childStreamId != parentStreamId : "A stream cannot depend on itself"; assert childStreamId > 0 && parentStreamId >= 0 : "childStreamId must be > 0. parentStreamId must be >= 0."; streamByteDistributor.updateDependencyTree(childStreamId, parentStreamId, weight, exclusive); } DefaultHttp2RemoteFlowController(Http2Connection connection);  DefaultHttp2RemoteFlowController(Http2Connection connection,
                                            StreamByteDistributor streamByteDistributor);  DefaultHttp2RemoteFlowController(Http2Connection connection, final Listener listener);  DefaultHttp2RemoteFlowController(Http2Connection connection,
                                            StreamByteDistributor streamByteDistributor,
                                            final Listener listener); @Override void channelHandlerContext(ChannelHandlerContext ctx); @Override ChannelHandlerContext channelHandlerContext(); @Override void initialWindowSize(int newWindowSize); @Override int initialWindowSize(); @Override int windowSize(Http2Stream stream); @Override boolean isWritable(Http2Stream stream); @Override void channelWritabilityChanged(); @Override void updateDependencyTree(int childStreamId, int parentStreamId, short weight, boolean exclusive); @Override void listener(Listener listener); @Override void incrementWindowSize(Http2Stream stream, int delta); @Override void addFlowControlled(Http2Stream stream, FlowControlled frame); @Override boolean hasFlowControlled(Http2Stream stream); @Override void writePendingBytes();  }