Rate Limiting requests

RateLimitedFetch.java

 public static List<Movie> invokeRateLimitedFetch(List<SearchedMovie> searchedMovies,boolean saveFile, File file){
        List<Movie> movies=new ArrayList<>();

           Observable.zip(Observable.from(searchedMovies),
                   Observable.interval(2, TimeUnit.SECONDS), (obs,timer)->obs)
                   .doOnNext(item -> {
                       Movie movie = movieUtil.getMovieDetails(item.getId());
                       movies.add(movie);
                       if(saveFile) {
                           writeRecordToFile(file, movie);
                       }
                   }




    ).toList().toBlocking().first();
     if(csvPrinter!=null){
         try {
             csvPrinter.close();
         } catch (IOException e) {

         }
     }
        return movies;
    }