用RxJava中的可观察对象替换回调

Question

我使用侦听器作为回调来观察Android的异步操作，但是我认为用RxJava替换此侦听器可能很棒，我是使用此库的新手，但是我真的很喜欢它，并且我始终将其与Android项目一起使用。

这是我的重构代码：

public void getData( final OnResponseListener listener ){
   if(data!=null && !data.isEmpty()){
       listener.onSuccess();
   }
   else{
       listener.onError();
   }
}

一个简单的回调：

public interface OnResponseListener {
   public void onSuccess();
   public void onError(); 
}

和“观察者”：

object.getData( new OnResponseListener() {
    @Override
    public void onSuccess() {
       Log.w(TAG," on success");
    }

    @Override
    public void onError() {
       Log.e(TAG," on error");
    }
});

谢谢！

Answer 1

例如，您可以使用 Observable.fromCallable 来创建可观察数据。

public Observable<Data> getData(){
    return Observable.fromCallable(() -> {
        Data result = null;
        //do something, get your Data object
        return result;
    });
}

然后使用您的数据

 getData().subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(data -> {
                //do something with your data
            }, error -> {
                //do something on error
            });

使用了rxjava 1.x和lambda表达式。

编辑：

如果我对您的理解很好，则您想替换该侦听器，而不是将其包装为可观察的。我添加了其他示例以参考您的评论。哦.. 如果您只希望一项，也应该使用 Single
。

public Single<Data> getData() {
        return Single.create(singleSubscriber -> {
            Data result = object.getData();
            if(result == null){
                singleSubscriber.onError(new Exception("no data"));
            } else {
                singleSubscriber.onSuccess(result);
            }
        });
    }

getData().subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(data -> {
                //do something with your data
            }, error -> {
                //do something on error
            });