Skip to content

Commit

Permalink
add Http1xZstdCompressionTest
Browse files Browse the repository at this point in the history
  • Loading branch information
sullis authored and vietj committed May 18, 2024
1 parent 31ea11b commit cf73109
Showing 1 changed file with 43 additions and 0 deletions.
43 changes: 43 additions & 0 deletions src/test/java/io/vertx/core/http/Http1xZstdCompressionTest.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,43 @@
package io.vertx.core.http;

import io.netty.buffer.ByteBuf;
import io.netty.handler.codec.MessageToByteEncoder;
import io.netty.handler.codec.compression.StandardCompressionOptions;
import io.netty.handler.codec.compression.Zstd;
import io.netty.handler.codec.compression.ZstdEncoder;
import org.junit.Assert;
import org.junit.BeforeClass;


public class Http1xZstdCompressionTest extends HttpCompressionTestBase {

@BeforeClass
public static void zstdLibraryIsAvailable() {
Assert.assertTrue(Zstd.isAvailable());
}

@Override
protected HttpServerOptions createBaseServerOptions() {
return new HttpServerOptions().setPort(DEFAULT_HTTP_PORT).setHost(DEFAULT_HTTP_HOST);
}

@Override
protected HttpClientOptions createBaseClientOptions() {
return new HttpClientOptions().setDefaultPort(DEFAULT_HTTP_PORT).setDefaultHost(DEFAULT_HTTP_HOST);
}

@Override
protected MessageToByteEncoder<ByteBuf> encoder() {
return new ZstdEncoder();
}

@Override
protected String encoding() {
return "zstd";
}

@Override
protected void configureServerCompression(HttpServerOptions options) {
options.setCompressionSupported(true).addCompressor(StandardCompressionOptions.zstd());
}
}

0 comments on commit cf73109

Please sign in to comment.