Task

RecommendationTask.java

@TaskDependency(ConfigTask.class)
	public Observable<ConfigDto> configTask;

	@TaskDependency(SiteTask.class)
	public Observable<SiteDto> siteTask;

	@TaskDependency(UserTask.class)
	public Observable<UserDto> userTask;

	@Inject
	public RecommendationsService recommendationsService;

	@Override
	public Observable<RecommendationsDto> get() {
		return Observable.merge(Observable.zip(configTask, siteTask, userTask, (configDto, siteDto, userDto) ->
			recommendationsService.getRecommendations(configDto, userDto, siteDto)));
	}