From 6710291bbdb1f46899e209111177ddc53089191f Mon Sep 17 00:00:00 2001 From: Juergen Hoeller Date: Fri, 18 May 2018 22:21:33 +0200 Subject: [PATCH] Polishing --- .../web/reactive/function/client/DefaultWebClient.java | 5 ++--- .../web/reactive/function/server/RequestPredicates.java | 3 +-- 2 files changed, 3 insertions(+), 5 deletions(-) diff --git a/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/DefaultWebClient.java b/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/DefaultWebClient.java index 3cac85cfc6b..482f52e2324 100644 --- a/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/DefaultWebClient.java +++ b/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/DefaultWebClient.java @@ -288,8 +288,8 @@ class DefaultWebClient implements WebClient { } @Override - public > RequestHeadersSpec body(P publisher, - ParameterizedTypeReference typeReference) { + public > RequestHeadersSpec body( + P publisher, ParameterizedTypeReference typeReference) { this.inserter = BodyInserters.fromPublisher(publisher, typeReference); return this; @@ -443,7 +443,6 @@ class DefaultWebClient implements WebClient { } private static Mono createResponseException(ClientResponse response) { - return DataBufferUtils.join(response.body(BodyExtractors.toDataBuffers())) .map(dataBuffer -> { byte[] bytes = new byte[dataBuffer.readableByteCount()]; diff --git a/spring-webflux/src/main/java/org/springframework/web/reactive/function/server/RequestPredicates.java b/spring-webflux/src/main/java/org/springframework/web/reactive/function/server/RequestPredicates.java index 06c70f97247..03bd27294ae 100644 --- a/spring-webflux/src/main/java/org/springframework/web/reactive/function/server/RequestPredicates.java +++ b/spring-webflux/src/main/java/org/springframework/web/reactive/function/server/RequestPredicates.java @@ -297,8 +297,8 @@ public abstract class RequestPredicates { * @param name the name of the query parameter to test against * @param value the value of the query parameter to test against * @return a predicate that matches if the query parameter has the given value - * @see ServerRequest#queryParam(String) * @since 5.0.7 + * @see ServerRequest#queryParam(String) */ public static RequestPredicate queryParam(String name, String value) { return queryParam(name, new Predicate() { @@ -306,7 +306,6 @@ public abstract class RequestPredicates { public boolean test(String s) { return s.equals(value); } - @Override public String toString() { return String.format("== %s", value);