Realm rxjava sample

getPersons.java

 public Observable<List<Person>> getPersons() {
        final Realm realm = Realm.getDefaultInstance();

        return realm.where(Person.class).findAll() //get Persons from DB
                .asObservable()
                .map(new Func1<RealmResults<Person>, List<Person>>() {
                    @Override
                    public List<Person> call(RealmResults<Person> person) {
                        return realm.copyToRealm(person); //Convert RealmResults to List
                    }
                }).doOnUnsubscribe(new Action0() {
                    @Override
                    public void call() {
                        realm.close();
                    }
                });
}
    
repository.getPersons()
                .doOnNext(new Action1<List<Person>>() {
                    @Override
                    public void call(List<Person> persons) {
                        personView.addPersons(persons); //Add data to ListView
                    }
                }).flatMapIterable(new Func1<List<Person>, Iterable<Person>>() {
                    @Override
                    public Iterable<Person> call(List<Person> persons) {
                        return persons;
                    }
                }).flatMap(new Func1<Person, Observable<Person>>() {
                    @Override
                    public Observable<Person> call(Person person) {
                        return repository.getGitHubData(person); //get each persons github data
                    }
                }).subscribe(new Subscriber<Person>() {
                    @Override
                    public void onCompleted() {
                        this.unsubscribe();
                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.e(TAG, e.getMessage());
                    }

                    @Override
                    public void onNext(Person person) {
                        personView.updatePerson(person); //Update data to ListView
                    }
                }));