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)