zip
-
Sequence 변환 OperatorSpring Reactive Web Application/Project Reactor 2023. 8. 5. 08:00
map map() Operator는 Upstream에서 emit된 데이터를 mapper Function을 사용하여 변환한 후, Downstream으로 emit 합니다. 다음은 Upstream에서 emit된 문자열의 일부인 'Circle'을 map() Operator 내부에서 replace() 메서드를 이용해 'Rectangle'로 변환 후 Downstream으로 emit 하는 예제 코드입니다. import lombok.extern.slf4j.Slf4j; import reactor.core.publisher.Flux; /** * map 예제 */ @Slf4j public class Example14_27 { public static void main(String[] args) { Flux .just("1-..
-
결합 연산자BackEnd/RxJava 2023. 7. 8. 07:00
merge 다수의 Observable에서 통지된 데이터를 받아서 다시 하나의 Observable로 통지합니다. 통지 시점이 빠른 Observable의 데이터부터 순차적으로 통지되고, 통지 시점이 같을 경우에는 merge() 함수의 파라미터로 먼저 지정된 Observable의 데이터부터 통지됩니다. package com.itvillage.chapter05.chapter0505; import com.itvillage.utils.LogType; import com.itvillage.utils.Logger; import com.itvillage.utils.TimeUtil; import io.reactivex.Observable; import java.util.concurrent.TimeUnit; /** * 두개..