Skip to content

Commit 4975e96

Browse files
committed
Merge 27d2920 into 1.1.6
2 parents ee51c39 + 27d2920 commit 4975e96

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

reactor-netty-http/src/test/java/reactor/netty/http/HttpProtocolsTests.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -457,8 +457,7 @@ void testResponseTimeout(HttpServer server, HttpClient client) throws Exception
457457
doTestResponseTimeout(localClient, 200);
458458
}
459459

460-
private void doTestResponseTimeout(HttpClient client, long expectedTimeout)
461-
throws Exception {
460+
private static void doTestResponseTimeout(HttpClient client, long expectedTimeout) throws Exception {
462461
AtomicBoolean onRequest = new AtomicBoolean();
463462
AtomicBoolean onResponse = new AtomicBoolean();
464463
AtomicBoolean onDisconnected = new AtomicBoolean();
@@ -530,7 +529,7 @@ void testConcurrentRequests_CustomPool(HttpServer server, HttpClient client) {
530529
doTestConcurrentRequests(client.port(disposableServer.port()));
531530
}
532531

533-
private void doTestConcurrentRequests(HttpClient client) {
532+
private static void doTestConcurrentRequests(HttpClient client) {
534533
List<String> responses =
535534
Flux.range(0, 10)
536535
.flatMapDelayError(i -> client.get()
@@ -611,7 +610,7 @@ void testTrailerHeadersFullResponse(HttpServer server, HttpClient client) {
611610
doTestTrailerHeaders(client.port(disposableServer.port()), "empty", "testTrailerHeadersFullResponse");
612611
}
613612

614-
private void doTestTrailerHeaders(HttpClient client, String expectedHeaderValue, String expectedResponse) {
613+
private static void doTestTrailerHeaders(HttpClient client, String expectedHeaderValue, String expectedResponse) {
615614
client.get()
616615
.uri("/")
617616
.responseSingle((res, bytes) -> bytes.asString().zipWith(res.trailerHeaders()))

0 commit comments

Comments
 (0)