返信時にフラットマップをテストする方法Observable.error

Question

を返すときにObservable.flatmapをテストしようとしていますが、良い方法が見つかりません。

@Override 
public Observable<List<MovieInfo>> getPopMoviesFromNet(int page) { 
    return Observable.just(page) 
      .flatMap(new Func1<Integer, Observable<List<MovieInfo>>>() { 
       @Override 
       public Observable<List<MovieInfo>> call(Integer page) { 
        try{ 
         List<MovieInfo> movies = MovieOkhttp.getMovieData(page); 
         return Observable.just(movies); 
        }catch (IOException e){ 
         return Observable.error(e); 
        } 
       } 
      }); 
} 

私はこれをモックしようとしています。repository

@Test 
public void getPopMoviesFromNetError() { 
    Mockito.when(repository.getPopMoviesFromNet(1)) 
      .thenReturn(Obserable.error(new IOException())); 
      //can not do 

} 

私はMockitoとunittestのに新しいですが、私は、私はObserable.flatmapをテストするための良い方法を見つけることができませんだと思うが、私はRxjavaが苦手だということです。

EXTRA：Rxjava 1.2

Answer 1

私はジェネリッククラスが得意ではないですそのため申し訳ありませんvideo

Mockito.when(repository.getPopMoviesFromNet(1)) 
     .thenReturn(Obserable.<List<MovieInfo>>error(new IOException())); 

から解を得ます。