diff --git a/src/main/java/io/vertx/core/http/impl/Http2ClientConnection.java b/src/main/java/io/vertx/core/http/impl/Http2ClientConnection.java index cfe48b100..17cc13b6d 100644 --- a/src/main/java/io/vertx/core/http/impl/Http2ClientConnection.java +++ b/src/main/java/io/vertx/core/http/impl/Http2ClientConnection.java @@ -277,15 +277,15 @@ class Http2ClientConnection extends Http2ConnectionBase implements HttpClientCon @Override void handlePriorityChange(StreamPriority streamPriority) { - if(streamPriority != null && !streamPriority.equals(streamPriority())) { - setStreamPriority(streamPriority); + if(streamPriority != null && !streamPriority.equals(priority())) { + priority(streamPriority); response.handlePriorityChange(streamPriority); } } void handleHeaders(Http2Headers headers, StreamPriority streamPriority, boolean end) { if(streamPriority != null) - setStreamPriority(streamPriority); + priority(streamPriority); if (response == null || response.statusCode() == 100) { int status; String statusMessage; @@ -363,7 +363,7 @@ class Http2ClientConnection extends Http2ConnectionBase implements HttpClientCon if (conn.metrics != null) { request.metric(conn.metrics.requestBegin(conn.queueMetric, conn.metric(), conn.localAddress(), conn.remoteAddress(), request)); } - setStreamPriority(streamPriority); + priority(streamPriority); writeHeaders(h, end && content == null); if (content != null) { writeBuffer(content, end); @@ -388,8 +388,8 @@ class Http2ClientConnection extends Http2ConnectionBase implements HttpClientCon @Override - public void updateStreamPriority(StreamPriority streamPriority) { - setStreamPriority(streamPriority); + public void updatePriority(StreamPriority streamPriority) { + priority(streamPriority); writePriorityFrame(); } diff --git a/src/main/java/io/vertx/core/http/impl/Http2ServerConnection.java b/src/main/java/io/vertx/core/http/impl/Http2ServerConnection.java index 55ffcdffb..97f57af5d 100644 --- a/src/main/java/io/vertx/core/http/impl/Http2ServerConnection.java +++ b/src/main/java/io/vertx/core/http/impl/Http2ServerConnection.java @@ -116,7 +116,7 @@ public class Http2ServerConnection extends Http2ConnectionBase { return; } Http2ServerRequestImpl req = createRequest(streamId, headers); - req.setStreamPriority(new StreamPriority(streamDependency, weight, exclusive)); + req.priority(new StreamPriority(streamDependency, weight, exclusive)); stream = req; CharSequence value = headers.get(HttpHeaderNames.EXPECT); @@ -184,7 +184,7 @@ public class Http2ServerConnection extends Http2ConnectionBase { Http2Stream promisedStream = handler.connection().stream(promisedStreamId); boolean writable = handler.encoder().flowController().isWritable(promisedStream); Push push = new Push(promisedStream, contentEncoding, method, path, writable, completionHandler); - push.setStreamPriority(streamPriority); + push.priority(streamPriority); streams.put(promisedStreamId, push); if (maxConcurrentStreams == null || concurrentStreams < maxConcurrentStreams) { concurrentStreams++; diff --git a/src/main/java/io/vertx/core/http/impl/Http2ServerRequestImpl.java b/src/main/java/io/vertx/core/http/impl/Http2ServerRequestImpl.java index 8a9a074a0..805e3658a 100644 --- a/src/main/java/io/vertx/core/http/impl/Http2ServerRequestImpl.java +++ b/src/main/java/io/vertx/core/http/impl/Http2ServerRequestImpl.java @@ -536,7 +536,7 @@ public class Http2ServerRequestImpl extends VertxHttp2Stream { void handleClose() { } - public void setStreamPriority(StreamPriority streamPriority) { + public void priority(StreamPriority streamPriority) { this.streamPriority = streamPriority; } - public StreamPriority streamPriority() { + public StreamPriority priority() { return streamPriority; }