[java] RxJava에서의 중첩된 실행 흐름 관리

28 Nov 2023

java

RxJava는 비동기적인 작업을 관리하기 위한 강력한 라이브러리입니다. 하지만 때로는 여러 비동기 작업이 중첩되어 실행되어야 할 필요가 있습니다. 이러한 경우에는 RxJava를 사용하여 중첩된 실행 흐름을 효과적으로 관리할 수 있습니다.

중첩된 Observable 사용하기

중첩된 실행 흐름을 관리하기 위해 RxJava에서는 flatMap 연산자를 제공합니다. flatMap은 입력 Observable의 각 아이템을 변환하고, 각 변환된 아이템을 새로운 Observable로 만들어줍니다. 이렇게 생성된 Observable들은 병렬로 실행될 수 있으며, 최종 결과는 모든 Observable의 결과가 도착한 시점에 합쳐집니다.

다음은 예제 코드입니다.

Observable.just("A", "B", "C")
    .flatMap(item ->
        Observable.just(item + "1", item + "2", item + "3")
            .subscribeOn(Schedulers.io())
    )
    .subscribe(result -> System.out.println(result));

위의 코드는 3개의 아이템(“A”, “B”, “C”)을 입력으로 받고, 각 아이템 뒤에 “1”, “2”, “3”을 붙여서 새로운 Observable을 만듭니다. 이때 subscribeOn(Schedulers.io())를 사용하여 새로운 Observable이 별도의 스레드에서 실행되도록 설정합니다. 마지막으로 결과를 구독하여 출력합니다.

중첩된 Completable 사용하기

만약 중첩된 실행 흐름을 사용하고자 하는 작업이 비동기적인 완료만 필요한 경우에는 Completable을 사용할 수 있습니다. Completable은 아무 값도 방출하지 않고, 단지 작업의 성공 또는 실패를 알려주는 역할을 합니다.

다음은 Completable을 사용하여 중첩된 실행 흐름을 관리하는 예제 코드입니다.

Completable.concatArray(
    Completable.fromAction(() -> login()),
    Completable.fromAction(() -> loadData()),
    Completable.fromAction(() -> displayData())
)
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(() -> System.out.println("작업이 완료되었습니다."),
        error -> System.out.println("작업 중 오류가 발생하였습니다."));

위의 코드는 세 가지 작업(login, loadData, displayData)을 순서대로 실행합니다. Completable.fromAction을 사용하여 각 작업을 Completable로 변환한 후, concatArray를 사용하여 순차적으로 실행합니다. subscribeOn(Schedulers.io())를 사용하여 작업이 별도의 스레드에서 실행되도록 설정하고, observeOn(AndroidSchedulers.mainThread())를 사용하여 결과의 처리를 메인 스레드에서 수행합니다. 결과는 성공 또는 실패에 따라 콜백 함수를 통해 처리됩니다.

결론

RxJava를 사용하여 중첩된 실행 흐름을 관리하면 비동기 작업을 효과적으로 조합하고 제어할 수 있습니다. flatMap을 사용하면 중첩된 Observable을 처리하고, Completable을 사용하면 중첩된 비동기 작업의 성공 또는 실패를 관리할 수 있습니다.

더 자세한 내용은 RxJava 공식 문서를 참조하시기 바랍니다.

RxJava 공식 문서: https://github.com/ReactiveX/RxJava