[RxJava] Completable 개념 이해

Completable

1. 개념

Completable은 데이터를 발행하는 Observable, Single, Maybe와 달리 데이터 발행의 완료/에러 신호만 보내는 특수한 형태이다. 따라서 데이터 발행의 완료를 알리는 onComplete와 에러 발생을 알리는 onError 2가지 알림을 보낸다.

• onComplete : 데이터 발행이 완료됐음을 알림
• onError : 에러가 발생했음을 알림

 

 

2. 예제

Completable은 just 연산자가 없으므로 create 연산자나 fromXXX를 통해 생성한다.
예제를 보면, Completable은 데이터 없이 완료했다 / 에러가 발생했다는 결과만 전달하고 종료한다.

Completable completed = Completable.create(new CompletableOnSubscribe() {
    @Override
    public void subscribe(@NonNull CompletableEmitter emitter) throws Throwable {
        emitter.onComplete();
    }
});
completed.subscribe(new Action() {
    @Override
    public void run() throws Throwable {
        System.out.println("onComplete");
    }
}, new Consumer<Throwable>() {
    @Override
    public void accept(Throwable throwable) throws Throwable {
        System.out.println("onError");
    }
});

Result:
onComplete

 

 

 

참고 글: Completable

http://reactivex.io/RxJava/3.x/javadoc/io/reactivex/rxjava3/core/Completable.html

 

2022.06.05 - [Programming Android[Java]] - [RxJava] Single 개념 이해

 

2022.06.12 - [Programming Android[Java]] - [RxJava] Maybe 개념 이해