Skip to content

Commit

Permalink
Merge 27d2920 into 2.0.0-M4
Browse files Browse the repository at this point in the history
  • Loading branch information
violetagg committed Apr 5, 2023
2 parents ddd0968 + 4975e96 commit 19f0a21
Showing 1 changed file with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -462,8 +462,7 @@ void testResponseTimeout(HttpServer server, HttpClient client) throws Exception
doTestResponseTimeout(localClient, 200);
}

private void doTestResponseTimeout(HttpClient client, long expectedTimeout)
throws Exception {
private static void doTestResponseTimeout(HttpClient client, long expectedTimeout) throws Exception {
AtomicBoolean onRequest = new AtomicBoolean();
AtomicBoolean onResponse = new AtomicBoolean();
AtomicBoolean onDisconnected = new AtomicBoolean();
Expand Down Expand Up @@ -535,7 +534,7 @@ void testConcurrentRequests_CustomPool(HttpServer server, HttpClient client) {
doTestConcurrentRequests(client.port(disposableServer.port()));
}

private void doTestConcurrentRequests(HttpClient client) {
private static void doTestConcurrentRequests(HttpClient client) {
List<String> responses =
Flux.range(0, 10)
.flatMapDelayError(i -> client.get()
Expand Down Expand Up @@ -616,7 +615,7 @@ void testTrailerHeadersFullResponse(HttpServer server, HttpClient client) {
doTestTrailerHeaders(client.port(disposableServer.port()), "empty", "testTrailerHeadersFullResponse");
}

private void doTestTrailerHeaders(HttpClient client, String expectedHeaderValue, String expectedResponse) {
private static void doTestTrailerHeaders(HttpClient client, String expectedHeaderValue, String expectedResponse) {
client.get()
.uri("/")
.responseSingle((res, bytes) -> bytes.asString().zipWith(res.trailerHeaders()))
Expand Down

0 comments on commit 19f0a21

Please sign in to comment.