RxJava (9) - Observable 오류 처리하기

Observable 오류 처리하기

데이터가 발행되다 보면, 은연중에 오류가 발행할 수도 있는 것이다. 그런데 보통 데이터 스트림에서 오류가 발생하면, 즉시 데이터 스트림이 종료되기 때문에 따로 조치를 해주어야 하는 상황이 있을 수 있다. 이번 포스팅에선 Observable에서 발생할 수 있는 에러를 핸들링하는 방법 몇 가지를 알아보자.

 

onError() Consumer 등록하기

이전에 Observable에서 에러가 발생하면 Emitter.onError() 이벤트를 발행하는 것을 배운적 있다. subscribe()안에 onNext() Consumer 뿐만 아니라 onError() Consumer를 넣어줌으로써, onError()를 구독할 수 있다. 가장 일반적인 에러 핸들링 기법이다.

fun main() {
    Observable.just("1", "2", "A", "3")
        .map { it.toInt() }
        .subscribe(System.out::println) {
            println(it)  // onError() Consumer
        }
}

[실행결과]
1
2
java.lang.NumberFormatException: For input string: "A"

map() 함수에서 문자열을 정수형으로 바꾸는 동작을 하고 있는데, A를 만난 순간 오류가 발생할 것이다. 이 때 발행된 onError()를 출력하는 구문을 subscribe()에 넣어줬더니, 정상적으로 출력된 것을 확인할 수 있다. 물론 에러가 발생한 이후 데이터는 더 이상 발행되지 않는다.

 

이것은 Consumer를 넘겨줌으로써 구현한 에러 핸들링인데, 이외에 오류 처리 전용 연산자를 활용하는 방법들도 있다. 아래를 살펴보자.

 

이것은 Consumer를 넘겨줌으로써 구현한 에러 핸들링인데, 이외에 오류 처리 전용 연산자를 활용하는 방법들도 있다. 아래를 살펴보자.

 

onErrorReturn() 메소드

 

이 녀석은 에러가 발생했을 때, onError() 이벤트 발생 대신 오류 처리를 위한 구문을 담은 함수를 실행한다.

fun main() {
    Observable.just("1", "2", "A", "3")
        .map { it.toInt() }
        .onErrorReturn { -1 }
        .subscribe { x: Int? -> println(x) }
}

[실행결과]
1
2
-1

 

 

onErrorResumeNext() 메소드

만약 에러가 발생한다면, 해당 데이터 스트림을 종료하고 기입해준 다름 Observable로 데이터 스트림을 교체하여 데이터를 발행하게 된다.

fun main() {
    Observable.just("1", "2", "A", "3")
        .map { it.toInt() }
        .onErrorResumeNext(Observable.just(10, 20, 30))
        .subscribe(System.out::println)
}

[실행결과]
1
2
10
20
30

A를 발행하다 오류가 발생하여, 새로운 Observable의 데이터 10부터 차례대로 발행되는 것을 확인할 수 있다. 매우 직관적인 메소드명이다.

 

 

retry() 메소드

다시 시도.. 말 그대로 데이터 발행을 재시도하게 하는 녀석이다. 에러가 발생할 경우, 다시 해당 Observable을 구독한다. (재구독) 하지만 무한 루프에 빠질 가능성이 있기 때문에, 횟수를 지정해주게 된다. (Long 타입)

fun main() {
    Observable.just("1", "2", "A", "3")
        .map { it.toInt() }
        .retry(3)
        .onErrorReturn { -1 }
        .subscribe(System.out::println)
}

[실행결과]
1
2
1
2
1
2
1
2
-1