Realm Rx asObservable() example

gistfile1.java

    private Subscription queryDogsByInput() {
        return RxTextView.textChanges(editText)
                         .switchMap(charSequence -> realm.where(Dog.class)
                                                         .contains(DogFields.NAME, charSequence.toString())
                                                         .findAllSortedAsync(DogFields.NAME)
                                                         .asObservable()
                        ).filter(RealmResults::isLoaded) // filter async results while not loaded
                         .subscribe(dogs -> adapter.updateData(dogs));
    }