query mapper for single object using Observable<T>

[ziahaqi]

i try to get single user data using Observer getUser(int id) method. but the subscriber dont get back enything, what wrong ? I've been using a query like this : return query(SELECT(USER_PROJECTION) .FROM(User.TABLE_NAME) .WHERE(User.COL_ID + " = ?")) .args(String.valueOf(userId)) .run() .mapToOne(new Func1<Cursor, User>() { @Override public User call(Cursor cursor) { //.... } }) I have tried mapToOne(UserMapper.MAPPER). and the result still same.

[sockeqwe]

Do you subscribed to that observable? Is Subscriber.onNext() or Subscriber.onError() really never called?

[ziahaqi]

yes i did. I already subscribe method on my Presenter by this way :

userObservable.observeOn(AndroidSchedulers.mainThread()). subscribe(new Subscriber() { @Override public void onCompleted() { Log.i(TAG, "onCompleted"); }

                        @Override
                        public void onError(Throwable e) {
                            mLoginView.showError(e.getMessage());
                        }

                        @Override
                        public void onNext(User user) {
                            mLoginView.onGetUserSuccess(user); 
                        }
                    });

[sockeqwe]

Can you provide me with some code that I can run and debug?

I really would be surprised if there is a bug in SQLBrite or SQLBrite-DAO