[RxJava] 다양한 Observable의 형태 ( Single )

안녕하세요 헬창코딩입니다.

오늘은 Observable의 다양한 형태에 대해서 알아보도록 하겠습니다!!

 

Single

SIngle은 Observable과는 다르게 단 하나의 아이템만을 발행하는 특징이 있습니다. 그러므로 저번 포스팅에서 알아보았던 just() 연산자에는 하나의 인자만을 취할 수 있습니다. 

        Single.just("health coding").subscribe(t -> Log.d("log_test", "" + t));

 

create() 연산자를 사용하는 경우 Emitter를 이용하여 데이터를 발행합니다. 데이터를 단 한 번만 발행하므로 onNext()와 onComplete()

메서드를 호출하는 대신 onSuccess(T)로 두메 서드를 대체합니다. 

Single.create(emitter -> emitter.onSuccess("health"))
                .subscribe(t -> Log.d("log_test", "" + t));

 

오류를 다루는 경우 Observable의 Emitter와 동일하게 onError()를 호출하여 오류를 구독자들에게 통지할 수 있습니다.

추가로 몇 가지의 Rxjava의 연산자들은 Observable의 Single로 변환시키곤 합니다. 

        Observable<Integer> data = Observable.just(1, 2, 3);
        Single<Boolean> single_1 = data.all(integer -> integer > 0);
        Single<Integer> single_2 = data.first(-1);
        Single<List<Integer>> single_3 = data.toList();

 

또한 Single도 필요에 따라 Observable로 변환해야 하는 경우가 있습니다. 그런 경우에는 toObservable() 연산자를 사용합니다.

Single<String> stringSingle = Single.just("health coding");
        Observable<String> observable = stringSingle.toObservable();

 

모든 소스의 경우에 Obsevable로 변환하는 것뿐만이 아니라 to~연산자를 이용하면 다른 소스의 형태로 바꾸는 것이 가능합니다. 

Single은 단일 아이템을 발행한다는 점에서 HTTP 요청/응답과 같은 이벤트를 처리할 때 종종 사용됩니다.