iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Improve Spring WebClient tutorial (#10993)

This commit is contained in:
Martin Tarjányi 2021-10-27 20:33:40 +02:00 committed by GitHub
parent 5ee276f972
commit 301961ade1
1 changed files with 5 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
spring-5-reactive-client/src/main/java/com/baeldung/reactive/webclient/simultaneous/Client.java
View File

@ -1,9 +1,8 @@
package com.baeldung.reactive.webclient.simultaneous; package com.baeldung.reactive.webclient.simultaneous;
import org.springframework.web.reactive.function.client.WebClient; import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;
import reactor.core.publisher.Flux; import reactor.core.publisher.Flux;
import reactor.core.scheduler.Schedulers; import reactor.core.publisher.Mono;
import java.util.List; import java.util.List;
import java.util.logging.Logger; import java.util.logging.Logger;
@ -19,8 +18,6 @@ public class Client {
} }
public Mono<User> getUser(int id) { public Mono<User> getUser(int id) {
LOG.info(String.format("Calling getUser(%d)", id));
return webClient.get() return webClient.get()
.uri("/user/{id}", id) .uri("/user/{id}", id)
.retrieve() .retrieve()
@ -43,22 +40,16 @@ public class Client {
public Flux<User> fetchUsers(List<Integer> userIds) { public Flux<User> fetchUsers(List<Integer> userIds) {
return Flux.fromIterable(userIds) return Flux.fromIterable(userIds)
.parallel() .flatMap(this::getUser);
.runOn(Schedulers.elastic())
.flatMap(this::getUser)
.ordered((u1, u2) -> u2.id() - u1.id());
} }
public Flux<User> fetchUserAndOtherUser(int id) { public Flux<User> fetchUserAndOtherUser(int id) {
return Flux.merge(getUser(id), getOtherUser(id)) return Flux.merge(getUser(id), getOtherUser(id));
.parallel()
.runOn(Schedulers.elastic())
.ordered((u1, u2) -> u2.id() - u1.id());
} }
public Mono<UserWithItem> fetchUserAndItem(int userId, int itemId) { public Mono<UserWithItem> fetchUserAndItem(int userId, int itemId) {
Mono<User> user = getUser(userId).subscribeOn(Schedulers.elastic()); Mono<User> user = getUser(userId);
Mono<Item> item = getItem(itemId).subscribeOn(Schedulers.elastic()); Mono<Item> item = getItem(itemId);
return Mono.zip(user, item, UserWithItem::new); return Mono.zip(user, item, UserWithItem::new);
} }