MapOperatorFragment.java 文件源码

@Override
public void onViewCreated(View view, @Nullable Bundle savedInstanceState) {
    super.onViewCreated(view, savedInstanceState);

    mRepoListView = view.findViewById(R.id.repo_list_view);
    mObserverLog = view.findViewById(R.id.observer_log);
    mObserverLog.setMovementMethod(new ScrollingMovementMethod());

    mApi.getObservableRepositories(Utils.USER)
            //For every repository, this method will add the number of this repository.
            .map(new Function<List<RepositoryResponse>, List<RepositoryResponse>>() {
                @Override
                public List<RepositoryResponse> apply(@NonNull List<RepositoryResponse> repositoryResponses) throws Exception {

                    for (int i = 1; i <= repositoryResponses.size(); i++) {
                        repositoryResponses.get(i - 1).name = "Repository N° "
                                + i
                                + ": "
                                + repositoryResponses.get(i - 1).name;
                    }
                    return repositoryResponses;
                }
            })
            //Subscribe the Network call in io Thread.
            .subscribeOn(Schedulers.io())
            //Subscribe the Observer in MainThread so it can updates the UI with the result.
            .observeOn(AndroidSchedulers.mainThread())
            //Choose the subscribed Observer for items emitted by this observable.
            .subscribe(mListBaseObserver);
}