将此 AsyncTask 转换为 RxAndroid

Question

对 Rx 来说有点新，所以我正在寻找一些关于将以下AsyncTask转换为 Rx 的帮助，希望这样我就可以用我已经知道的代码更多地可视化 Rx。我发现了其他一些有些相关的 SO 答案，但其中很多不是网络请求，许多人使用不同的运算符来提供不同的答案，所以我有点困惑。

这是AsyncTask：

public class BackgroundStuff extends AsyncTask<Void, Void, Void> {
    @Override
    protected Void doInBackground(Void... params) {
        UserAgent myUserAgent = UserAgent.of("xxx:xxxx:xxx");
        RedditClient redditClient = new RedditClient(myUserAgent);
        Credentials credentials = Credentials.userlessApp("xxxxxxxx", UUID.randomUUID());
        OAuthData authData = null;
        try {
            authData = redditClient.getOAuthHelper().easyAuth(credentials);
            redditClient.authenticate(authData);
        } catch (OAuthException e) {
            e.printStackTrace();
        }
        SubredditPaginator sp = new SubredditPaginator(redditClient);
        sp.setLimit(7);
        sp.setSorting(Sorting.HOT);
        sp.setTimePeriod(TimePeriod.DAY);
        sp.setSubreddit("pics");
        sp.next(true);
        Listing<Submission> list = sp.getCurrentListing();
        Submission sub = list.get(1);
        for (Submission submission : list) {
            Log.d("test", "title: " + submission.getTitle());
        }
        Submission sub2 = redditClient.getSubmission(sub.getId());
        System.out.println(sub2.getComments().get(0).getComment().getBody());

        return null;
    }
}

作为参考，这会向Reddit进行身份验证，然后从特定的subreddit获取一些结果。

我知道我需要Observable，然后.suscribeOn(Schedulers.newThread())和.observeOn(AndroidSchedulers.mainThread())，但不确定如何使可观察。

Answer 1

将其包装在函数中：

    Void doSomething(){
    UserAgent myUserAgent = UserAgent.of("xxx:xxxx:xxx");
    RedditClient redditClient = new RedditClient(myUserAgent);
    Credentials credentials = Credentials.userlessApp("xxxxxxxx", UUID.randomUUID());
    OAuthData authData = null;
    try {
        authData = redditClient.getOAuthHelper().easyAuth(credentials);
        redditClient.authenticate(authData);
    } catch (OAuthException e) {
        e.printStackTrace();
    }
    SubredditPaginator sp = new SubredditPaginator(redditClient);
    sp.setLimit(7);
    sp.setSorting(Sorting.HOT);
    sp.setTimePeriod(TimePeriod.DAY);
    sp.setSubreddit("pics");
    sp.next(true);
    Listing<Submission> list = sp.getCurrentListing();
    Submission sub = list.get(1);
    for (Submission submission : list) {
        Log.d("test", "title: " + submission.getTitle());
    }
    Submission sub2 = redditClient.getSubmission(sub.getId());
    System.out.println(sub2.getComments().get(0).getComment().getBody());

    return null;
    }

将其包装在可观察量中：

Observable.just(doSomething);

将其包装在延迟中，以便仅在有人订阅时运行：

Observable<Void> doSomethingObservable = Observable.defer(()-> Observable.just(doSomething))

确定它将在 subscribeOn 和 ObserveOn 中运行的位置，并订阅它以使其运行：

doSomethingObservable
.suscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread()).subscribe();