--- a/src/java.net.http/share/classes/jdk/internal/net/http/Stream.java Mon May 28 10:48:38 2018 +0100
+++ b/src/java.net.http/share/classes/jdk/internal/net/http/Stream.java Mon May 28 17:22:37 2018 +0100
@@ -202,6 +202,7 @@
Log.logTrace("responseSubscriber.onComplete");
if (debug.on()) debug.log("incoming: onComplete");
sched.stop();
+ connection.decrementStreamsCount(streamid);
subscriber.onComplete();
onCompleteCalled = true;
setEndStreamReceived();
--- a/src/java.net.http/share/classes/jdk/internal/net/http/frame/SettingsFrame.java Mon May 28 10:48:38 2018 +0100
+++ b/src/java.net.http/share/classes/jdk/internal/net/http/frame/SettingsFrame.java Mon May 28 17:22:37 2018 +0100
@@ -166,7 +166,7 @@
// TODO: check these values
f.setParameter(ENABLE_PUSH, 1);
f.setParameter(HEADER_TABLE_SIZE, 4 * K);
- f.setParameter(MAX_CONCURRENT_STREAMS, 35);
+ f.setParameter(MAX_CONCURRENT_STREAMS, 100);
f.setParameter(INITIAL_WINDOW_SIZE, 64 * K - 1);
f.setParameter(MAX_FRAME_SIZE, 16 * K);
return f;