public abstract class ResponseExtractors extends Object
Constructor and Description |
---|
ResponseExtractors() |
Modifier and Type | Method and Description |
---|---|
static <T> BodyExtractor<reactor.core.publisher.Mono<T>> |
as(Class<T> sourceClass)
Extract the response body and decode it, returning it as a
Mono<T> |
static <T> BodyExtractor<reactor.core.publisher.Mono<T>> |
as(ResolvableType bodyType)
Extract the response body and decode it, returning it as a
Mono<T> . |
static <T> BodyExtractor<reactor.core.publisher.Flux<T>> |
asStream(Class<T> sourceClass)
Extract the response body and decode it, returning it as a
Flux<T> |
static <T> BodyExtractor<reactor.core.publisher.Flux<T>> |
asStream(ResolvableType bodyType)
Extract the response body and decode it, returning it as a
Flux<T> |
static <T> ResponseExtractor<reactor.core.publisher.Mono<T>> |
body(Class<T> sourceClass)
Extract the response body and decode it, returning it as a
Mono<T> . |
static <T> ResponseExtractor<reactor.core.publisher.Mono<T>> |
body(ResolvableType bodyType)
Extract the response body and decode it, returning it as a
Mono<T> . |
static <T> ResponseExtractor<reactor.core.publisher.Flux<T>> |
bodyStream(Class<T> sourceClass)
Extract the response body and decode it, returning it as a
Flux<T> . |
static <T> ResponseExtractor<reactor.core.publisher.Flux<T>> |
bodyStream(ResolvableType bodyType)
Extract the response body and decode it, returning it as a
Flux<T> . |
protected static <T> reactor.core.publisher.Flux<T> |
decodeResponseBody(ClientHttpResponse response,
ResolvableType responseType,
List<HttpMessageReader<?>> messageReaders) |
protected static <T> reactor.core.publisher.Mono<T> |
decodeResponseBodyAsMono(ClientHttpResponse response,
ResolvableType responseType,
List<HttpMessageReader<?>> messageReaders) |
static ResponseExtractor<reactor.core.publisher.Mono<HttpHeaders>> |
headers()
Extract the response headers as an
HttpHeaders instance. |
protected static HttpMessageReader<?> |
resolveMessageReader(List<HttpMessageReader<?>> messageReaders,
ResolvableType responseType,
MediaType contentType) |
static <T> ResponseExtractor<reactor.core.publisher.Mono<ResponseEntity<T>>> |
response(Class<T> bodyClass)
Extract the full response body as a
ResponseEntity with its body decoded as
a single type T . |
static <T> ResponseExtractor<reactor.core.publisher.Mono<ResponseEntity<T>>> |
response(ResolvableType bodyType)
Extract the full response body as a
ResponseEntity with its body decoded as
a single type T . |
static <T> ResponseExtractor<reactor.core.publisher.Mono<ResponseEntity<reactor.core.publisher.Flux<T>>>> |
responseStream(Class<T> sourceClass)
Extract the full response body as a
ResponseEntity with its body decoded as
a Flux<T> . |
static <T> ResponseExtractor<reactor.core.publisher.Mono<ResponseEntity<reactor.core.publisher.Flux<T>>>> |
responseStream(ResolvableType type)
Extract the full response body as a
ResponseEntity with its body decoded as
a Flux<T> . |
public static <T> ResponseExtractor<reactor.core.publisher.Mono<T>> body(ResolvableType bodyType)
Mono<T>
.public static <T> ResponseExtractor<reactor.core.publisher.Mono<T>> body(Class<T> sourceClass)
Mono<T>
.public static <T> BodyExtractor<reactor.core.publisher.Mono<T>> as(ResolvableType bodyType)
Mono<T>
.public static <T> BodyExtractor<reactor.core.publisher.Mono<T>> as(Class<T> sourceClass)
Mono<T>
public static <T> ResponseExtractor<reactor.core.publisher.Flux<T>> bodyStream(ResolvableType bodyType)
Flux<T>
.public static <T> ResponseExtractor<reactor.core.publisher.Flux<T>> bodyStream(Class<T> sourceClass)
Flux<T>
.public static <T> BodyExtractor<reactor.core.publisher.Flux<T>> asStream(ResolvableType bodyType)
Flux<T>
public static <T> BodyExtractor<reactor.core.publisher.Flux<T>> asStream(Class<T> sourceClass)
Flux<T>
public static <T> ResponseExtractor<reactor.core.publisher.Mono<ResponseEntity<T>>> response(ResolvableType bodyType)
ResponseEntity
with its body decoded as
a single type T
.public static <T> ResponseExtractor<reactor.core.publisher.Mono<ResponseEntity<T>>> response(Class<T> bodyClass)
ResponseEntity
with its body decoded as
a single type T
.public static <T> ResponseExtractor<reactor.core.publisher.Mono<ResponseEntity<reactor.core.publisher.Flux<T>>>> responseStream(ResolvableType type)
ResponseEntity
with its body decoded as
a Flux<T>
.public static <T> ResponseExtractor<reactor.core.publisher.Mono<ResponseEntity<reactor.core.publisher.Flux<T>>>> responseStream(Class<T> sourceClass)
ResponseEntity
with its body decoded as
a Flux<T>
.public static ResponseExtractor<reactor.core.publisher.Mono<HttpHeaders>> headers()
HttpHeaders
instance.protected static <T> reactor.core.publisher.Flux<T> decodeResponseBody(ClientHttpResponse response, ResolvableType responseType, List<HttpMessageReader<?>> messageReaders)
protected static <T> reactor.core.publisher.Mono<T> decodeResponseBodyAsMono(ClientHttpResponse response, ResolvableType responseType, List<HttpMessageReader<?>> messageReaders)
protected static HttpMessageReader<?> resolveMessageReader(List<HttpMessageReader<?>> messageReaders, ResolvableType responseType, MediaType contentType)