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

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

오늘은  Rxjava의 Observable의 형태중 Completable에 대해 알아보겠습니다. 

 

Completable은 아이템을 발행하지 않고, 단지 정상적으로 실행이 종료되었는지에 대해 관심을 갖습니다.

그러므로 Emitter에서 onNext()난 onSuccess() 같은 메서드는 없고 onComplete()와 onError()만 존재합니다.

 

 Completable.create(emitter -> {
            emitter.onComplete();
        }).subscribe(() -> Log.d("log_test", "onComplete"));

결과

 

 

        Completable.fromRunnable(() -> {

        }).subscribe(() -> Log.d("log_test", "onComplete_2"));

결과