flatmap
-
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. 7. 07:00
map 원본 Observable에서 통지하는 데이터를 원하는 값으로 변환 후 통지합니다. 변환 전, 후 데이터 타입은 달라도 상관 없습니다. null을 반환하면 NullPointException이 발생하므로 null이 아닌 데이터 하나를 반드시 반환해야 합니다. package com.itvillage.chapter05.chapter0503; import com.itvillage.utils.LogType; import com.itvillage.utils.Logger; import io.reactivex.Observable; import java.util.Arrays; import java.util.List; /** * Observable이 통지한 항목에 함수를 적용하여 통지된 값을 변환시킨다. */ pub..