RxJava subscribeOn, observeOn

 

2022.08.07 - 스케쥴러(Scheduler) 종류

 

private Disposable data1Task;

//작업 환경 생성, RxJava 이해 필요.
data1Task = Observable.fromCallable(()->{
	//async work   
    return "result xxx";
})
.subscribeOn(Schedulers.io()) //work
.observeOn(AndroidSchedulers.mainThread()) //dsp
.subscribe(rststr -> { //result
	data1Task.dispose();
	qv("work end: " + rststr);
}, throwable -> qv("ec: " + throwable.toString()));

 

subscribeOn: 작업 thread 지정

observeOn: 작업 후 결과 처리 thread 지정