【发布时间】：2018-06-15 14:04:51
【问题描述】：
好的，所以我刚刚开始了一个新的 Android 项目，并想尝试实现 Bob 叔叔的 Clean Architecture。我在使用 RxJava 以及来自 GitHub 示例和样板以及 Fernando Cerjas 的博客（如 this article）的内容方面有了一个不错的开始，但对于如何实现一些用例仍有一些疑问。
TL;DR
实体是否应该具有另一个实体的字段（在我的示例中，User 具有 List<Messages> 字段）？
或者 Presenter 应该结合 UseCases 来构建一个映射到多个实体上的 ViewModel（那么你如何编写映射器代码？）？
或者，Presenter 是否应该有一个与每个 UseCase/Entity 关联的 ViewModel，并创建某种“等待所有数据到 onNext”来为每个 ViewModel 调用 view.show()？
基本上，UseCases 应该只返回实体吗？实体可以由其他实体组成（如在类的字段中）吗？实体只是愚蠢的数据模型 POJO 吗？如何表示“加入 SQL”查询？
举个例子，让我们以一个简单的用户/消息应用为例。
我要实现两个视图：UserList 和UserDetails：
-
UserList显示Users的列表 -
UserDetails显示用户的信息及其最新消息。
UserList 非常简单，我可以看到如何编写相关的 UseCase 和层（代码如下）。
我的问题在于UserDetails 屏幕。
如果我希望同时在视图中传递所有数据（例如构建由 User 类和字段 List 组成的 ViewModel），我应该如何编码我的 GetUserInfoUseCase？ GetUserInfoUseCase 的返回值应该是多少？
我应该编写Observable<User> GetUserInfoUseCase 和Observable<List<Message>> GetUserLatestMessages 并以某种方式在我的演示者中合并它们吗？如果是，我该如何管理，因为我的 Presenter 中没有 Observables（我只传递了一个 Observer 作为我的 UseCases 参数）？
用户实体
public abstract class User {
public abstract long id();
public abstract String name();
...
}
消息实体
public abstract class Message {
public abstract long id();
public abstract long senderId();
public abstract String text();
public abstract long timstamp();
...
}
GetUsersUseCase
public class GetUsersUseCase extends UseCaseObservableWithParameter<Boolean, List<User>, UsersRepository> {
@Inject
public GetUsersUseCase(UsersRepository UsersRepository,
@Named("Thread") Scheduler threadScheduler,
@Named("PostExecution") Scheduler postExecutionScheduler) {
super(usersRepository, threadScheduler, postExecutionScheduler);
}
@Override
protected Observable<List<User>> buildObservable(Boolean forceRefresh) {
if(forceRefresh)
repository.invalidateCache();
return repository.getUsers();
}
}
UsersPresenter
public class UsersPresenter extends BasePresenter<UsersContract.View> implements UsersContract.Presenter {
@Inject
GetUsersUseCase mGetUsersUseCase;
@Inject
UserViewModelMapper mUserMapper;
@Inject
public UsersPresenter() {
}
@Override
public void attachView(UsersContract.View mvpView) {
super.attachView(mvpView);
}
@Override
public void detachView() {
super.detachView();
mGetUsersUseCase.unsubscribe();
}
@Override
public void fetchUsers(boolean forceRefresh) {
getMvpView().showProgress();
mGetUsersUseCase.execute(forceRefresh, new DisposableObserver<List<User>>() {
@Override
public void onNext(List<User> users) {
getMvpView().hideProgress();
getMvpView().showUsers(mUsersMapper.mapUsersToViewModels(users));
}
@Override
public void onComplete() {
}
@Override
public void onError(Throwable e) {
getMvpView().hideProgress();
getMvpView().showErrorMessage(e.getMessage());
}
});
}
}
UseCaseObservableWithParameter
public abstract class UseCaseObservableWithParameter<REQUEST_DATA, RESPONSE_DATA, REPOSITORY> extends UseCase<Observable, REQUEST_DATA, RESPONSE_DATA, REPOSITORY> {
public UseCaseObservableWithParameter(REPOSITORY repository, Scheduler threadScheduler, Scheduler postExecutionScheduler) {
super(repository, threadScheduler, postExecutionScheduler);
}
protected abstract Observable<RESPONSE_DATA> buildObservable(REQUEST_DATA requestData);
public void execute(REQUEST_DATA requestData, DisposableObserver<RESPONSE_DATA> useCaseSubscriber) {
this.disposable.add(
this.buildObservable(requestData)
.subscribeOn(threadScheduler)
.observeOn(postExecutionScheduler)
.subscribeWith(useCaseSubscriber)
);
}
}
用例
public abstract class UseCase<OBSERVABLE, REQUEST_DATA, RESPONSE_DATA, REPOSITORY> {
protected final REPOSITORY repository;
protected final Scheduler threadScheduler;
protected final Scheduler postExecutionScheduler;
protected CompositeDisposable disposable = new CompositeDisposable();
public UseCase(REPOSITORY repository,
@Named("Thread") Scheduler threadScheduler,
@Named("PostExecution") Scheduler postExecutionScheduler) {
Timber.d("UseCase CTOR");
this.repository = repository;
this.threadScheduler = threadScheduler;
this.postExecutionScheduler = postExecutionScheduler;
}
protected abstract OBSERVABLE buildObservable(REQUEST_DATA requestData);
public boolean isUnsubscribed() {
return disposable.size() == 0;
}
public void unsubscribe() {
if (!isUnsubscribed()) {
disposable.clear();
}
}
}
【问题讨论】：
标签： android architecture clean-architecture