@Test
public void listWatchingRepo() throws Exception {

    TestSubscriber<List<RepositoryInfo>> subscriber = TestSubscriber.create();
    userDataSource.listWatchingRepo("TellH", 1).subscribe(subscriber);
    List<List<RepositoryInfo>> onNextEvents = subscriber.getOnNextEvents();
    assertNotNull(onNextEvents);
    System.out.println(onNextEvents.get(0).toString());
}