RxJava with AsyncTask and Activity in android

Question

我有一个小时的RxJava经验，我正在尝试在我的项目中实现它，而不是使用接口和监听器。

我有一个异步任务，它在单独的模块中调用谷歌云端点方法，并在完成后收到List<Profile>。

在异步任务的onPostExecute()方法中，我调用 onNext，以便任何订阅者都能收到此数据。

以下是AsyncTask的外观：

private BirthpayApi mApi;
private String mUserId;
private ReplaySubject<List<Profile>> notifier = ReplaySubject.create();
public GetFriends(String userId) {
    mUserId = userId;
}
public Observable<List<Profile>> asObservable() {
    return notifier;
}
@Override
protected List<Profile> doInBackground(Void... params) {
    if (mApi == null) {
        BirthpayApi.Builder builder = new BirthpayApi.Builder(AndroidHttp.newCompatibleTransport(),
                    new AndroidJsonFactory(), null)
                    // options for running against local devappserver
                    // - 10.0.2.2 is localhost's IP address in Android emulator
                    // - turn off compression when running against local devappserver
                    .setRootUrl("http://10.0.2.2:8080/_ah/api/")
                    .setGoogleClientRequestInitializer(new GoogleClientRequestInitializer() {
                    @Override
                    public void initialize(AbstractGoogleClientRequest<?> abstractGoogleClientRequest) throws IOException {
                            abstractGoogleClientRequest.setDisableGZipContent(true);
                        }
                    });
            mApi = builder.build();
    }
    try {
        return mApi.getFriends(mUserId).execute().getItems();
    } catch (IOException e) {
        e.printStackTrace();
        return null;
    }
}
@Override
protected void onPostExecute(List<Profile> friends) {
    super.onPostExecute(friends);
    notifier.onNext(friends);
}

在我的片段中，我想从调用onNext()方法的异步任务中收集这些数据。因此，我在声明我的类时使用implements Action1<List<Profile>>，这也扩展了 Fragment。

在来自 Action1 接口的 onCall() 方法中，我收集从异步任务发送的数据：

@Override
public void call(List<Profile> profiles) {
    if (profiles.size() > 0) {
        updateAdapter(profiles);
    } else
        setUpNoFriendsViews();
}

我正在关注树屋，但他们使用一个对象来建模他们的数据，这些数据成为可观察的，而不是使用异步类，他们使用适配器作为观察者。我做错了吗，无论哪种方式，我如何让它工作？

Answer 1

看起来您不像是在订阅您在任何地方创建的可观察对象，也不清楚您在 AsyncTask 上在哪里调用 execute。 另外，我不认为你会想要一个重播主题，但这取决于你想要实现什么。

除此之外，我建议完全切换到Rx，而不是混合Rx和AsyncTasks。在这种情况下，在模型类中创建一个类似这样的方法：

public Observable<List<Profile>> getProfiles() {
    return Observable.defer(new Func0<Observable<List<Profile>>>() {
        @Override
        public Observable<List<Profile>> call() {
            if (mApi == null) {
                BirthpayApi.Builder builder = new BirthpayApi.Builder(AndroidHttp.newCompatibleTransport(),
                        new AndroidJsonFactory(), null)
                        // options for running against local devappserver
                        // - 10.0.2.2 is localhost's IP address in Android emulator
                        // - turn off compression when running against local devappserver
                        .setRootUrl("http://10.0.2.2:8080/_ah/api/")
                        .setGoogleClientRequestInitializer(new GoogleClientRequestInitializer() {
                            @Override
                            public void initialize(AbstractGoogleClientRequest<?> abstractGoogleClientRequest) throws IOException {
                                abstractGoogleClientRequest.setDisableGZipContent(true);
                            }
                        });
                mApi = builder.build();
            }
            try {
                List<Profile> profiles = mApi.getFriends(mUserId).execute().getItems();
                return Observable.just(profiles);
            } catch (IOException e) {
                return Observable.error(e);
            }
        }
    });
}

然后在您的片段中：

modal.getProfiles()
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(
        new Action1<List<Profile>>() {
                //...
        },
        new Action1<Throwable>() {
            @Override
            public void call(Throwable throwable) {
                throwable.printStackTrace();
            }
        }
    );