android 将回调替换为 RxJava2 中的可观察对象

问：

37

我使用回调来观察 Android 的异步操作，但我认为用 RxJava 替换这个侦听器会很棒，当回调调用 onError 时，我还需要重试 3 次。

这是我要重构的代码：

public int search(String from, String searchContent, @NonNull Config config, QueryCallback<S=Result> callback) {

}


public interface QueryCallback<T> {
    void onError(int var1);

    void onSuccess(T var1);
}

完整的电话会议如下：

FlowPlayControl.getInstance().search(from, 
searchContent, config, 
                            new QueryCallback<Result>() {
                                @Override
                                public void onError(int i) {
                                    .....
                                }
                                
                                @Override
                                public void onSuccess(Result result) {
                                    ......
                                });

我需要使用 Rxjava 替换回调