flatMap 알아보기
Flux.range(1, 10).flatMap( A ).map(i -> i * 10).subscribe(System.out::println); flatMap이 어떻게 동작하는지 알아보기 위해, 다음 코드의 동작을 잘 살펴보려 한다. A에 함수에 따라 달라지는 동작을 그림과 함께 살펴보자. (flatMap의 비동기성을 잘 살펴보기 위해 스레드는 1개로 제한할 것이다.) # 1. 1초 후에 인자를 단순히 Mono로 감싸 반환하는 함수를 사용 Flux.range(1, 10).flatMap(this::sleepAndWrap).map(i -> i * 10).subscribe(System.out::println); private Mono sleepAndWrap(int i) { return Mono.just(i).m..
Reactive Programmingaaa/쓸데없이 자세한 Reactor
2021. 3. 9. 04:28