mindol1004/reactor-ddd
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

gradle config correction

Browse Source
This commit is contained in:
Michal Zeman
2020-07-26 10:23:14 +02:00
parent 090975ec26
commit e26a0f962a
6 changed files with 38 additions and 39 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
common-components/src/main/java/com/mz/reactor/ddd/common/components/http/HttpHandler.java
View File

@@ -8,6 +8,7 @@ import org.springframework.web.reactive.function.server.ServerResponse;
import reactor.core.publisher.Mono;
import reactor.core.scheduler.Scheduler;
import static com.mz.reactor.ddd.common.components.http.HttpHandlers.deserializeJsonString;
import static org.springframework.web.reactive.function.BodyInserters.fromObject;
public interface HttpHandler {
@@ -18,12 +19,12 @@ public interface HttpHandler {
default <T> Mono<T> bodyToMono(ServerRequest request, Class<T> clazz, Scheduler scheduler) {
return request.bodyToMono(String.class)
.flatMap(HttpHandlerFunctions.FN.deserializeJsonString(clazz, scheduler, mapper()));
.flatMap(deserializeJsonString(clazz, scheduler, mapper()));
}
default <T> Mono<T> bodyToMono(ServerRequest request, Class<T> clazz) {
return request.bodyToMono(String.class)
.flatMap(HttpHandlerFunctions.FN.deserializeJsonString(clazz, mapper()));
.flatMap(deserializeJsonString(clazz, mapper()));
}
default <T> Mono<ServerResponse> mapToResponse(T result) {

10
common-components/src/main/java/com/mz/reactor/ddd/common/components/http/HttpHandlerFunctions.java → common-components/src/main/java/com/mz/reactor/ddd/common/components/http/HttpHandlers.java
View File

@@ -15,9 +15,9 @@ import java.util.function.Function;
import static org.springframework.web.reactive.function.BodyInserters.fromObject;
public enum HttpHandlerFunctions {
FN;
public final class HttpHandlers {
private HttpHandlers() {}
// private final ObjectMapper mapper;
//
// HttpHandlerFunctions() {
@@ -26,7 +26,7 @@ public enum HttpHandlerFunctions {
// mapper.registerModule(new Jdk8Module());
// }
public <T> Function<String, Mono<T>> deserializeJsonString(
public static <T> Function<String, Mono<T>> deserializeJsonString(
@Nonnull Class<T> clazz,
@Nonnull Scheduler scheduler,
@Nonnull ObjectMapper mapper
@@ -34,11 +34,11 @@ public enum HttpHandlerFunctions {
return value -> Mono.fromCallable(() -> mapper.readValue(value, clazz)).subscribeOn(scheduler);
}
public <T> Function<String, Mono<T>> deserializeJsonString(@Nonnull Class<T> clazz, @Nonnull ObjectMapper mapper) {
public static <T> Function<String, Mono<T>> deserializeJsonString(@Nonnull Class<T> clazz, @Nonnull ObjectMapper mapper) {
return value -> Mono.fromCallable(() -> mapper.readValue(value, clazz)).subscribeOn(Schedulers.elastic());
}
public <E extends Throwable> Mono<ServerResponse> onError(E e, ServerRequest req, Consumer<E> logger) {
public static <E extends Throwable> Mono<ServerResponse> onError(E e, ServerRequest req, Consumer<E> logger) {
return Mono.fromCallable(() -> {
logger.accept(e);
return ErrorMessage.builder().error(e.getMessage()).build();