--- a/src/java.net.http/share/classes/jdk/internal/net/http/Http2Connection.java Mon May 28 17:22:37 2018 +0100
+++ b/src/java.net.http/share/classes/jdk/internal/net/http/Http2Connection.java Fri May 25 16:13:11 2018 +0100
@@ -28,7 +28,6 @@
import java.io.EOFException;
import java.io.IOException;
import java.io.UncheckedIOException;
-import java.lang.System.Logger.Level;
import java.net.InetSocketAddress;
import java.net.URI;
import java.nio.ByteBuffer;
@@ -54,7 +53,7 @@
import jdk.internal.net.http.HttpConnection.HttpPublisher;
import jdk.internal.net.http.common.FlowTube;
import jdk.internal.net.http.common.FlowTube.TubeSubscriber;
-import jdk.internal.net.http.common.HttpHeadersImpl;
+import jdk.internal.net.http.common.HttpHeadersBuilder;
import jdk.internal.net.http.common.Log;
import jdk.internal.net.http.common.Logger;
import jdk.internal.net.http.common.MinimalFuture;
@@ -82,7 +81,6 @@
import static java.nio.charset.StandardCharsets.UTF_8;
import static jdk.internal.net.http.frame.SettingsFrame.*;
-
/**
* An Http2Connection. Encapsulates the socket(channel) and any SSLEngine used
* over it. Contains an HttpConnection which hides the SocketChannel SSL stuff.
@@ -792,7 +790,7 @@
nextPushStream += 2;
}
- HttpHeadersImpl headers = decoder.headers();
+ HttpHeaders headers = decoder.headers();
HttpRequestImpl pushReq = HttpRequestImpl.createPushRequest(parentReq, headers);
Exchange<T> pushExch = new Exchange<>(pushReq, parent.exchange.multi);
Stream.PushedStream<T> pushStream = createPushStream(parent, pushExch);
@@ -1303,10 +1301,10 @@
static class HeaderDecoder extends ValidatingHeadersConsumer {
- HttpHeadersImpl headers;
+ HttpHeadersBuilder headersBuilder;
HeaderDecoder() {
- this.headers = new HttpHeadersImpl();
+ this.headersBuilder = new HttpHeadersBuilder();
}
@Override
@@ -1314,11 +1312,11 @@
String n = name.toString();
String v = value.toString();
super.onDecoded(n, v);
- headers.addHeader(n, v);
+ headersBuilder.addHeader(n, v);
}
- HttpHeadersImpl headers() {
- return headers;
+ HttpHeaders headers() {
+ return headersBuilder.build();
}
}