From: Kai Moritz Date: Thu, 21 Nov 2019 13:57:25 +0000 (+0100) Subject: WIP: WebClient X-Git-Tag: wip-webclient~24 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=14d0788aed0305a814fc87bc33f3f17771dc6858;p=facebook-errors WIP: WebClient --- 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(