RxJava in Android & Sample

Rx개념 기존 callback 방식이 아닌, event 기반으로 event를 목적에 맞게 구독하며, event 내용을 조건(filter)/변형(transform)/구독(subscribe) 등을 해가며 처리하는 방식. platform 레벨에서 지원해줘서 사용이 쉽고, 안정적이다.

callback 지옥으로 부터 벗어나고, 목적내용을 조립적으로 구성하여 가독성과 유지보수를 쉽게한다.

실재 장점

비동기 작업에 처리하기 위한, AsyncTask 를 만들고 인터페이스들(callback)을 구현하는 boilerplate 줄여줌. 특히 연속적인 비동기작업도 쉽게 구현가능
이벤트(데이터)를 쉽게 가공, 분배 할수있어 다양한 조건에 맞는 대응 동작을 간편하게 구현가능

Observable(관찰/구독 대상) / Observer(관찰/구독 자)

React의 핵심개념은, 이벤트기반으로 데이터가 흘러가니, ViewModel, Controller, View.. 등에서 서로간의 통신에 대한 interface를 만들거나, 비동기후의 getter/setter 등의 동기문제들으로 부터 자유로워 진다.

Operator

filter ( boolean expression ) 몇가지 더 제공
Kollection - kotlin collection 에서 제공되는 operator 들 [http://jussi.hallila.com/Kollections/]

Scheduler 참고

AndroidSchedulers.mainThread() - 안드로이드의 UI 스레드에서 동작합니다.
Schedulers.io() - 동기 I/O를 별도로 처리시켜 비동기 효율을 얻기 위한 스케줄러입니다. 자체적인 스레드 풀 CachedThreadPool을 사용합니다. API 호출 등 네트워크를 사용한 호출 시 사용됩니다.
Schedulers.newThread() - 새로운 스레드를 만드는 스케쥴러입니다.
Schedulers.computation() - 이벤트 룹에서 간단한 연산이나 콜백 처리를 위해 사용됩니다. RxComputationThreadPool라는 별도의 스레드 풀에서 돌아갑니다. 최대 cpu갯수 개의 스레드 풀이 순환하면서 실행됩니다.
Schedulers.immediate() - 현재 스레드에서 즉시 수행합니다. observeOn()이 여러번 쓰였을 경우 immediate()를 선언한 바로 윗쪽의 스레드를 따라갑니다.
Schedulers.from(executor) - 특정 executor를 스케쥴러로 사용합니다.
Schedulers.trampoline() - 큐에 있는 일이 끝나면 이어서 현재 스레드에서 수행하는 스케쥴러.
HandlerScheduler.from(handler) - 특정 핸들러 handler에 의존하여 동작합니다.

subscribeOn, observeOn

SubscribeOn은 Observable이 작동 할 스케줄러를 지정합니다. 링크 ObserveOn은 관찰자가 Observable 을 관찰 할 스케줄러를 지정하십시오. 링크 작동(UI작업이라던가, Handler), 관찰(로깅, 트레이싱)을 하는 작업의 내용

Disposable (버릴수있는)

Observable 에서 생성하는 이벤트 스트림과 필요로하는 리소스 관리 CompositeDisposable 을 통해 Activity/Fragment Lifecycle 에 맞는 request cancel 효과를 구현할수있다.

Retrofit & RxJava 연동 Sample

프로젝트 진행하며, 필수 전처리

1. 프로젝트 추가 책 Sample

해당 챕터 내용만 저희 프로젝트로 추가
2. Github App 추가

oAuth를 위한 임의의 App을 생성 oAuth callback 을 통한 onNewIntent 가 호출되도록 callback url(scheme) 지정

1. 라이브러리 추가

// project > build.gradle > buildscript  > ext.retrofitVersion 2.4.0 정의
implementation "com.squareup.retrofit2:retrofit:$retrofitVersion"
    implementation "com.squareup.retrofit2:converter-gson:$retrofitVersion"
    implementation "com.squareup.retrofit2:adapter-rxjava2:$retrofitVersion"

2. Retrofit.addCallAdapterFacroty()

//  GithubApiProvider.kt
Retrofit.Builder()
.addCallAdapterFactory(RxJava2CallAdapterFactory.createAsync())
//Call Adapter 에 RxJava에서 제공하는 Scheduler 와 비동기 작업처리에 대한 instance 생성.

RxJava Observable 로 만드는 과정은, method 참고

RxJava2CallAdapterFactory.class
  public CallAdapter<?, ?> get(Type returnType, Annotation[] annotations, Retrofit retrofit)

Disposable & Map(transform)

 private fun getAccessToken(code: String) {
        var gettingAccessTokenObservable = api.getAccessToken( // : Observable<GithubAccessToken>
                BuildConfig.GITHUB_CLIENT_ID, BuildConfig.GITHUB_CLIENT_SECRET, code)
                .map { it.accessToken } // 이후부터 string 으로 변경됨.
                .observeOn(AndroidSchedulers.mainThread())
                .doOnSubscribe { showProgress() }
                .doOnTerminate { hideProgress() }
                .subscribe({ token ->
                    authTokenProvider.updateToken(token)
                    launchMainActivity()
                }) {
                    showError(it)
                }
//        disposables.add(gettingAccessTokenObservable)
        disposables += gettingAccessTokenObservable
//
    }

RxBinding

JakeWharton 이 만든 View/Lifecycle 에 특화된 observe 이벤트 발생 https://github.com/JakeWharton/RxBinding

샘플 ViewPager(paging), RecyclerView(scroll & pre-loading), Button(toggle) Sample

Devik0213 / memo