IT LAB

[Project Reactor] 4. Which operator do I need?

1. Creating a New Sequence…​Lazy하게 생성하는 방식을 제공함✅ Subscription 시점에 실제 값을 생성함 APIAPI설명핵심Mono.fromCallable()반환값이 있는 작업을 Subscription 시점에 실행하여 Mono로 생성반환값 → onNext, Exception → onErrorMono.fromRunnable()반환값이 없는 작업을 Reactive Sequence로 생성값 없이 완료 여부만 표현 예제) Mono.fromCallable()더보기Mono userMono = Mono.fromCallable(() -> userRepository.findById(1L)) .subscribeOn(Schedulers.boundedElastic());Bloc..

[Project Reactor] 3. Three Sorts of Batching

많은 데이터를 묶음 단위로 나누는 방식을 제공함 1. Grouping with Flux>같은 Key를 가진 데이터끼리 묶는 방식하나의 값은 하나의 그룹에만 속함✅ 각 그룹은 GroupedFlux⚠️ 생성된 GroupedFlux를 실제로 소비해야 데이터를 가져올 수 있음API설명핵심groupBy(Function)같은 Key를 가진 데이터를 각각의 GroupedFlux로 분리Flux → Flux>concatMap()생성된 Group을 하나씩 순차적으로 소비A 그룹 완료 → B 그룹 → C 그룹, 그룹 간 순서 보장예제) groupBy()더보기Flux.just(1, 3, 5, 2, 4, 6) .groupBy(i -> i % 2 == 0 ? "even" : "odd"); 예제) concatMap()더보기F..