public class RxJava1ResponseExtractors extends Object
ResponseExtractor and BodyExtractor,
based on the Observable and Single APIs.| Constructor and Description |
|---|
RxJava1ResponseExtractors() |
| Modifier and Type | Method and Description |
|---|---|
static <T> BodyExtractor<rx.Single<T>> |
as(Class<T> sourceClass)
Extract the response body and decode it, returning it as a
Single<T> |
static <T> BodyExtractor<rx.Single<T>> |
as(ResolvableType bodyType)
Extract the response body and decode it, returning it as a
Single<T>. |
static <T> BodyExtractor<rx.Observable<T>> |
asStream(Class<T> sourceClass)
Extract the response body and decode it, returning it as a
Observable<T>. |
static <T> BodyExtractor<rx.Observable<T>> |
asStream(ResolvableType bodyType)
Extract the response body and decode it, returning it as a
Observable<T>. |
static <T> ResponseExtractor<rx.Single<T>> |
body(Class<T> sourceClass)
Extract the response body and decode it, returning it as a
Single<T>. |
static <T> ResponseExtractor<rx.Single<T>> |
body(ResolvableType bodyType)
Extract the response body and decode it, returning it as a
Single<T>. |
static <T> ResponseExtractor<rx.Observable<T>> |
bodyStream(Class<T> sourceClass)
Extract the response body and decode it, returning it as an
Observable<T>. |
static <T> ResponseExtractor<rx.Observable<T>> |
bodyStream(ResolvableType bodyType)
Extract the response body and decode it, returning it as an
Observable<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<rx.Single<HttpHeaders>> |
headers()
Extract the response headers as an
HttpHeaders instance. |
protected static HttpMessageReader<?> |
resolveMessageReader(List<HttpMessageReader<?>> messageReaders,
ResolvableType responseType,
MediaType contentType) |
static <T> ResponseExtractor<rx.Single<ResponseEntity<T>>> |
response(Class<T> sourceClass)
Extract the full response body as a
ResponseEntity
with its body decoded as a single type T. |
static <T> ResponseExtractor<rx.Single<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<rx.Single<ResponseEntity<rx.Observable<T>>>> |
responseStream(Class<T> sourceClass)
Extract the full response body as a
ResponseEntity
with its body decoded as an Observable<T>. |
static <T> ResponseExtractor<rx.Single<ResponseEntity<rx.Observable<T>>>> |
responseStream(ResolvableType bodyType)
Extract the full response body as a
ResponseEntity
with its body decoded as an Observable<T> |
public static <T> ResponseExtractor<rx.Single<T>> body(ResolvableType bodyType)
Single<T>.public static <T> ResponseExtractor<rx.Single<T>> body(Class<T> sourceClass)
Single<T>.public static <T> BodyExtractor<rx.Single<T>> as(ResolvableType bodyType)
Single<T>.public static <T> BodyExtractor<rx.Single<T>> as(Class<T> sourceClass)
Single<T>public static <T> ResponseExtractor<rx.Observable<T>> bodyStream(ResolvableType bodyType)
Observable<T>public static <T> ResponseExtractor<rx.Observable<T>> bodyStream(Class<T> sourceClass)
Observable<T>.public static <T> BodyExtractor<rx.Observable<T>> asStream(ResolvableType bodyType)
Observable<T>.public static <T> BodyExtractor<rx.Observable<T>> asStream(Class<T> sourceClass)
Observable<T>.public static <T> ResponseExtractor<rx.Single<ResponseEntity<T>>> response(ResolvableType bodyType)
ResponseEntity
with its body decoded as a single type T.public static <T> ResponseExtractor<rx.Single<ResponseEntity<T>>> response(Class<T> sourceClass)
ResponseEntity
with its body decoded as a single type T.public static <T> ResponseExtractor<rx.Single<ResponseEntity<rx.Observable<T>>>> responseStream(Class<T> sourceClass)
ResponseEntity
with its body decoded as an Observable<T>.public static <T> ResponseExtractor<rx.Single<ResponseEntity<rx.Observable<T>>>> responseStream(ResolvableType bodyType)
ResponseEntity
with its body decoded as an Observable<T>public static ResponseExtractor<rx.Single<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)