Switch to Reactor Californium SNAPSHOTs

See gh-14507
pull/14449/merge
Brian Clozel 6 years ago
parent 0f88ea658c
commit 1b7325df52

@ -143,7 +143,7 @@
<quartz.version>2.3.0</quartz.version>
<querydsl.version>4.2.1</querydsl.version>
<rabbit-amqp-client.version>5.4.1</rabbit-amqp-client.version>
<reactor-bom.version>Californium-RC1</reactor-bom.version>
<reactor-bom.version>Californium-BUILD-SNAPSHOT</reactor-bom.version>
<rest-assured.version>3.1.1</rest-assured.version>
<reactive-streams.version>1.0.2</reactive-streams.version>
<rxjava.version>1.3.8</rxjava.version>

@ -123,7 +123,7 @@ public class NettyReactiveWebServerFactory extends AbstractReactiveWebServerFact
server = compressionCustomizer.apply(server);
}
server = server.protocol(listProtocols());
server = (this.useForwardHeaders ? server.forwarded() : server.noForwarded());
server = server.forwarded(this.useForwardHeaders);
return applyCustomizers(server);
}

@ -307,7 +307,7 @@ public abstract class AbstractReactiveWebServerFactoryTests {
.getWebServer(new CharsHandler(3000, MediaType.TEXT_PLAIN));
this.webServer.start();
HttpClient client = HttpClient.create().wiretap().compress().tcpConfiguration(
HttpClient client = HttpClient.create().wiretap().compress(true).tcpConfiguration(
(tcpClient) -> tcpClient.doOnConnected((connection) -> connection
.channel().pipeline().addBefore(NettyPipeline.HttpDecompressor,
"CompressionTest", new CompressionDetectionHandler())));

Loading…
Cancel
Save