### Question:
RepositoryDataSource { public Observable<List<UserEntity>> listWatchers(String owner, String repo, int page) { return repositoryApi.listWatchers(owner, repo, page) .compose(RxJavaUtils.<List<UserEntity>>applySchedulers()); } RepositoryDataSource(RepositoryService repositoryApi); Observable<RepositoryInfo> getRepoInfo(String owner, String repo); Observable<List<RepositoryInfo>> listForks(String owner, String repo, int page); Observable<List<UserEntity>> listWatchers(String owner, String repo, int page); Observable<List<UserEntity>> listStargazers(String owner, String repo, int page); Observable<List<UserEntity>> listContributors(String owner, String repo, int page); Observable<RepositoryInfo> toFork(String owner, String repo); Observable<Boolean> toStar(String owner, String repo); Observable<Boolean> toWatch(String owner, String repo); Observable<Boolean> unStar(String owner, String repo); Observable<Boolean> unWatch(String owner, String repo); Observable<Boolean> checkStarred(String owner, String repo); Observable<Boolean> checkWatching(String owner, String repo); Observable<Boolean> delete(String owner, String repo); Observable<List<Branch>> listBranches(String owner, String repo); Observable<List<TreeNode>> getContent(final String owner, final String repo, final Branch branch); Observable<SearchResult<RepositoryInfo>> search(String keyWord, String language, int page); Observable<SearchResult<RepositoryInfo>> search(String keyWord, String language, SortType_Repo sort, int page); Observable<ReadMe> getReadMe(String owner, String repo);  }### Answer:
@Test public void listWatchers() throws Exception { TestSubscriber<List<UserEntity>> subscriber = TestSubscriber.create(); repositoryDataSource.listWatchers("TellH", "GitClub", 1).subscribe(subscriber); List<UserEntity> userList = subscriber.getOnNextEvents().get(0); assertNotNull(userList); System.out.println(userList.toString()); }