Skip to content

Commit 7b1c42e

Browse files
committed
Simplify HttpServerConfig compression to only require HttpCompressionOptions and configure the supported flag with the presence or absence of the compression config.
1 parent f86ea16 commit 7b1c42e

File tree

5 files changed

+8
-12
lines changed

5 files changed

+8
-12
lines changed

vertx-core/src/test/java/io/vertx/test/http/HttpConfig.java

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -82,13 +82,14 @@ public HttpServerConfig setDecompressionSupported(boolean supported) {
8282
return this;
8383
}
8484
@Override
85-
public HttpServerConfig setCompressionSupported(boolean supported) {
86-
options.setCompressionSupported(supported);
87-
return this;
88-
}
89-
@Override
9085
public HttpServerConfig setCompression(HttpCompressionOptions compression) {
91-
options.setCompression(compression);
86+
if (compression != null) {
87+
options.setCompressionSupported(true);
88+
options.setCompression(compression);
89+
} else {
90+
options.setCompressionSupported(false);
91+
options.setCompression(null);
92+
}
9293
return this;
9394
}
9495
@Override

vertx-core/src/test/java/io/vertx/test/http/HttpServerConfig.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,6 @@
99
public interface HttpServerConfig {
1010

1111
HttpServerConfig setDecompressionSupported(boolean supported);
12-
HttpServerConfig setCompressionSupported(boolean supported);
1312
HttpServerConfig setCompression(HttpCompressionOptions compression);
1413
HttpServerConfig setMaxFormBufferedBytes(int maxFormBufferedBytes);
1514
HttpServerConfig setMaxFormAttributeSize(int maxSize);

vertx-core/src/test/java/io/vertx/tests/http/compression/Http1xCompressionTest.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,6 @@ public void testServerCompressionBelowThreshold() throws Exception {
4949
public void testServerCompressionAboveThreshold() throws Exception {
5050
// set compression threshold to be less than the content string size so it WILL be compressed
5151
HttpServerConfig httpServerOptions = config.forServer();
52-
httpServerOptions.setCompressionSupported(true);
5352
httpServerOptions.setCompression(serverCompressionConfig().get().setContentSizeThreshold(COMPRESS_TEST_STRING.length() / 2));
5453

5554
doTest(httpServerOptions, onSuccess(resp -> {

vertx-core/src/test/java/io/vertx/tests/http/compression/Http1xCompressionThresholdTest.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,6 @@ protected Optional<HttpCompressionOptions> serverCompressionConfig() {
5454
public void testServerCompressionBelowThreshold() throws Exception {
5555
// set compression threshold to be greater than the content string size so it WILL NOT be compressed
5656
HttpServerConfig httpServerOptions = config.forServer();
57-
httpServerOptions.setCompressionSupported(true);
5857
httpServerOptions.setCompression(new HttpCompressionOptions()
5958
.addCompressor(CompressionConfig.gzip(6).compressor)
6059
.setContentSizeThreshold(COMPRESS_TEST_STRING.length() * 2)
@@ -77,7 +76,6 @@ public void testServerCompressionBelowThreshold() throws Exception {
7776
public void testServerCompressionAboveThreshold() throws Exception {
7877
// set compression threshold to be less than the content string size so it WILL be compressed
7978
HttpServerConfig config = this.config.forServer();
80-
config.setCompressionSupported(true);
8179
config.setCompression(new HttpCompressionOptions()
8280
.addCompressor(CompressionConfig.gzip(6).compressor)
8381
.setContentSizeThreshold(COMPRESS_TEST_STRING.length() / 2)

vertx-core/src/test/java/io/vertx/tests/http/compression/HttpCompressionTest.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ protected final Optional<HttpCompressionOptions> serverCompressionConfig() {
7979
@Test
8080
public void testSkipEncoding() throws Exception {
8181
server.close();
82-
server = config.forServer().setCompressionSupported(true).create(vertx);
82+
server = config.forServer().setCompression(new HttpCompressionOptions().addCompressor(CompressionConfig.gzip(6).compressor)).create(vertx);
8383
server.requestHandler(req -> {
8484
assertNotNull(req.headers().get(HttpHeaders.ACCEPT_ENCODING));
8585
req.response()
@@ -119,7 +119,6 @@ private void testServerStandardCompression(Function<HttpServerResponse, Future<?
119119
waitFor(2);
120120
server.close();
121121
HttpServerConfig options = config.forServer();
122-
options.setCompressionSupported(true);
123122
options.setCompression(serverCompressionConfig().get());
124123
server = options.create(vertx);
125124
server.requestHandler(req -> {

0 commit comments

Comments
 (0)