[java] RxJava에서의 데이터 변환

28 Nov 2023

java

RxJava는 리액티브 프로그래밍을 지원하는 라이브러리로, 비동기적인 작업을 쉽게 처리할 수 있도록 도와줍니다. 데이터 변환은 RxJava를 사용할 때 매우 중요한 개념 중 하나입니다. 데이터 변환을 올바르게 수행하면 코드의 가독성과 유지보수성을 향상시킬 수 있습니다.

Map 연산자

Map 연산자는 RxJava에서 가장 기본적인 데이터 변환 연산자입니다. 이 연산자는 각각의 데이터 항목에 함수를 적용하여 변환하는 역할을 합니다. 예를 들어, 정수를 받아와서 해당 정수에 10을 더한 결과를 방출하는 경우 다음과 같이 Map 연산자를 사용할 수 있습니다.

Observable<Integer> source = Observable.just(1, 2, 3, 4, 5);
Observable<Integer> result = source.map(number -> number + 10);
result.subscribe(number -> System.out.println(number));

위의 코드에서는 source Observable에서 발행되는 각 정수에 map 연산자를 적용하여 10을 더하고, 결과를 result Observable에 방출합니다. 마지막으로 result Observable을 구독하여 결과를 출력합니다.

FlatMap 연산자

FlatMap 연산자는 Map 연산자와 유사하게 동작하지만, 각각의 데이터 항목을 관찰할 때마다 새로운 Observable을 생성할 수 있습니다. 이렇게 생성된 Observable은 독립적으로 비동기적으로 실행됩니다.

Observable<Integer> source = Observable.just(1, 2, 3, 4, 5);
Observable<Integer> result = source.flatMap(number -> {
    if (number % 2 == 0) {
        return Observable.just(number * 2);
    } else {
        return Observable.just(number);
    }
});
result.subscribe(number -> System.out.println(number));

위의 코드에서는 source Observable에서 발행되는 각 정수에 flatMap 연산자를 적용하여 짝수인 경우 2를 곱한 결과를, 홀수인 경우 그대로 방출하는 작업을 수행합니다. 반환된 Observable은 독립적으로 실행되며 결과를 result Observable에 방출합니다.

다른 데이터 변환 연산자들

RxJava에는 Map과 FlatMap 이외의 다양한 데이터 변환 연산자들이 있습니다. 예를 들어, Filter 연산자는 조건에 맞는 데이터만 필터링하여 방출하는 역할을 합니다. Merge 연산자는 여러 개의 Observable을 하나의 Observable로 합치는 역할을 수행합니다.

이 외에도 데이터를 변환하거나 가공하는 다양한 연산자들이 있으니, 자세한 내용은 RxJava 공식 문서를 참조하시기 바랍니다.

결론

RxJava에서 데이터 변환은 비동기적인 작업을 처리하는 데 매우 유용한 기능입니다. Map과 FlatMap을 비롯한 다양한 연산자들을 적절히 활용하여 데이터를 변환하고 가공함으로써 더욱 효율적이고 가독성 높은 코드를 작성할 수 있습니다.

References

RxJava 공식 문서