diff --git a/spring-web/src/main/java/org/springframework/web/client/reactive/ResponseExtractors.java b/spring-web/src/main/java/org/springframework/web/client/reactive/ResponseExtractors.java index ca835fc6e4e..f3fedce1e5d 100644 --- a/spring-web/src/main/java/org/springframework/web/client/reactive/ResponseExtractors.java +++ b/spring-web/src/main/java/org/springframework/web/client/reactive/ResponseExtractors.java @@ -31,7 +31,7 @@ import reactor.core.publisher.Mono; /** * Static factory methods for {@link ResponseExtractor} based on the {@link Flux} and - * {@link Mono} API. + * {@link Mono} APIs. * * @author Brian Clozel * @since 5.0 @@ -41,7 +41,7 @@ public class ResponseExtractors { private static final Object EMPTY_BODY = new Object(); /** - * Extract the response body and decode it, returning it as a {@code Mono} + * Extract the response body and decode it, returning it as a {@code Mono}. * @see ResolvableType#forClassWithGenerics(Class, Class[]) */ @SuppressWarnings("unchecked") @@ -53,7 +53,7 @@ public class ResponseExtractors { } /** - * Extract the response body and decode it, returning it as a {@code Mono} + * Extract the response body and decode it, returning it as a {@code Mono}. */ public static ResponseExtractor> body(Class sourceClass) { ResolvableType bodyType = ResolvableType.forClass(sourceClass); @@ -61,7 +61,7 @@ public class ResponseExtractors { } /** - * Extract the response body and decode it, returning it as a {@code Flux} + * Extract the response body and decode it, returning it as a {@code Flux}. * @see ResolvableType#forClassWithGenerics(Class, Class[]) */ public static ResponseExtractor> bodyStream(ResolvableType bodyType) { @@ -70,7 +70,7 @@ public class ResponseExtractors { } /** - * Extract the response body and decode it, returning it as a {@code Flux} + * Extract the response body and decode it, returning it as a {@code Flux}. */ public static ResponseExtractor> bodyStream(Class sourceClass) { ResolvableType bodyType = ResolvableType.forClass(sourceClass); @@ -79,7 +79,7 @@ public class ResponseExtractors { /** * Extract the full response body as a {@code ResponseEntity} with its body decoded as - * a single type {@code T} + * a single type {@code T}. * @see ResolvableType#forClassWithGenerics(Class, Class[]) */ @SuppressWarnings("unchecked") @@ -100,7 +100,7 @@ public class ResponseExtractors { /** * Extract the full response body as a {@code ResponseEntity} with its body decoded as - * a single type {@code T} + * a single type {@code T}. */ public static ResponseExtractor>> response( Class bodyClass) { @@ -110,7 +110,7 @@ public class ResponseExtractors { /** * Extract the full response body as a {@code ResponseEntity} with its body decoded as - * a {@code Flux} + * a {@code Flux}. * @see ResolvableType#forClassWithGenerics(Class, Class[]) */ public static ResponseExtractor>>> responseStream( @@ -123,7 +123,7 @@ public class ResponseExtractors { /** * Extract the full response body as a {@code ResponseEntity} with its body decoded as - * a {@code Flux} + * a {@code Flux}. */ public static ResponseExtractor>>> responseStream( Class sourceClass) { @@ -132,7 +132,7 @@ public class ResponseExtractors { } /** - * Extract the response headers as an {@code HttpHeaders} instance + * Extract the response headers as an {@code HttpHeaders} instance. */ public static ResponseExtractor> headers() { return (clientResponse, messageConverters) -> clientResponse.map(resp -> resp.getHeaders()); @@ -160,4 +160,5 @@ public class ResponseExtractors { return messageConverters.stream().filter(e -> e.canRead(type, mediaType)) .findFirst(); } -} \ No newline at end of file + +} diff --git a/spring-web/src/main/java/org/springframework/web/client/reactive/support/RxJava1ResponseExtractors.java b/spring-web/src/main/java/org/springframework/web/client/reactive/support/RxJava1ResponseExtractors.java index b12263f9681..ce528e2d718 100644 --- a/spring-web/src/main/java/org/springframework/web/client/reactive/support/RxJava1ResponseExtractors.java +++ b/spring-web/src/main/java/org/springframework/web/client/reactive/support/RxJava1ResponseExtractors.java @@ -36,14 +36,15 @@ import rx.Single; /** * Static factory methods for {@link ResponseExtractor} - * based on the {@link Observable} and {@link Single} API. + * based on the {@link Observable} and {@link Single} APIs. * * @author Brian Clozel + * @since 5.0 */ -public class RxJava1ResponseExtractors { +public class RxJava1ResponseExtractors { /** - * Extract the response body and decode it, returning it as a {@code Single} + * Extract the response body and decode it, returning it as a {@code Single}. */ @SuppressWarnings("unchecked") public static ResponseExtractor> body(Class sourceClass) { @@ -55,7 +56,7 @@ public class RxJava1ResponseExtractors { } /** - * Extract the response body and decode it, returning it as an {@code Observable} + * Extract the response body and decode it, returning it as an {@code Observable}. */ public static ResponseExtractor> bodyStream(Class sourceClass) { @@ -67,7 +68,7 @@ public class RxJava1ResponseExtractors { /** * Extract the full response body as a {@code ResponseEntity} - * with its body decoded as a single type {@code T} + * with its body decoded as a single type {@code T}. */ @SuppressWarnings("unchecked") public static ResponseExtractor>> response(Class sourceClass) { @@ -86,7 +87,7 @@ public class RxJava1ResponseExtractors { /** * Extract the full response body as a {@code ResponseEntity} - * with its body decoded as an {@code Observable} + * with its body decoded as an {@code Observable}. */ public static ResponseExtractor>>> responseStream(Class sourceClass) { ResolvableType resolvableType = ResolvableType.forClass(sourceClass); @@ -99,7 +100,7 @@ public class RxJava1ResponseExtractors { } /** - * Extract the response headers as an {@code HttpHeaders} instance + * Extract the response headers as an {@code HttpHeaders} instance. */ public static ResponseExtractor> headers() { return (clientResponse, messageConverters) -> RxJava1SingleConverter @@ -124,4 +125,5 @@ public class RxJava1ResponseExtractors { ResolvableType type, MediaType mediaType) { return messageConverters.stream().filter(e -> e.canRead(type, mediaType)).findFirst(); } -} \ No newline at end of file + +}