RxJava/ RxAndroid

• Sample Code sample which replaces AsyncTaskLoader to load db data

SampleCode

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15

private void loadDBData() { Observable.defer(new Func0<Observable<List<String>>>() { @Override public Observable<List<String>> call() { Log.d(TAG, "call " + Thread.currentThread().getName()); List<String> stringList = DBHelperUtil.getPasswordEntries(); return Observable.just(stringList); } }) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(this); }

1 2 3 4 5 6 7 8 9 10 11

@Override public void onCompleted() { } @Override public void onError(Throwable e) { } @Override public void onNext(List<String> strings) { }