Я новичок в программировании весенней реакции, я создал пример конечной точки отдыха, в которой он публикует сообщения для клиента, у меня Mono>, который я пытаюсь получить доступ к объекту карты, чтобы проверить наличие значений в карта для этого я использую faltMap, но он не вызывается.
@ GetMapping ("/ test") publi c Publisher getName () {
Flux<Domain> name = Flux.<Domain>generate(msg -> msg.next(new Domain("test"))).take(50);
Map<String, String> map = new HashMap<>();
map.put("appId1", "App1");
map.put("appId2", "App2");
Mono<Map<String,String>> monoMap = Mono.just(map);
//monoMap.subscribe(System.out::println); //its print the map values //{appId1=App1, appId2=App2}
//Flow is not going inside the flatmap where i am trying to print the value from hashmap
monoMap.flatMap(names -> {
names.entrySet().stream()
.forEach(e -> System.out.println(e.getKey() + ":" + e.getValue()));
return Mono.just(names);
});
return name;
}
Не понимаю, что Я сделал ошибку, пожалуйста, помогите мне, если кто-нибудь знает.
Спасибо