From 14d0788aed0305a814fc87bc33f3f17771dc6858 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Thu, 21 Nov 2019 14:57:25 +0100 Subject: [PATCH] WIP: WebClient --- .../juplo/facebook/errors/GraphApiException.java | 14 +++++--------- 1 file changed, 5 insertions(+), 9 deletions(-) diff --git a/src/main/java/de/juplo/facebook/errors/GraphApiException.java b/src/main/java/de/juplo/facebook/errors/GraphApiException.java index b82a05b..2e56e62 100644 --- a/src/main/java/de/juplo/facebook/errors/GraphApiException.java +++ b/src/main/java/de/juplo/facebook/errors/GraphApiException.java @@ -10,12 +10,10 @@ import java.io.IOException; import java.io.InputStream; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.springframework.core.io.buffer.DataBuffer; import org.springframework.http.HttpHeaders; import org.springframework.http.HttpStatus; -import org.springframework.http.ReactiveHttpInputMessage; -import org.springframework.web.reactive.function.BodyExtractor.Context; import org.springframework.web.reactive.function.client.ClientResponse; +import reactor.core.publisher.Mono; @@ -49,13 +47,11 @@ public class GraphApiException extends RuntimeException public static GraphApiException create(ClientResponse response) { - return + Mono body = response - .body((ReactiveHttpInputMessage message, Context context) -> - message - .getBody() - .map(buffer -> buffer.asInputStream())) - .flatMap(is -> create(response.statusCode(), message.getHeaders(), is)); + .bodyToMono(String.class); + Mono e = body + .map(str -> create(response.statusCode(), null, str.getBytes())); } public static GraphApiException create( -- 2.20.1