SearchPlaceInteractorImpl.java

public class SearchPlaceInteractorImpl extends SearchOffsetLimitIneractor {

     private final PlaceDataProvider placeDataProvider;

     public SearchPlaceInteractorImpl(ThreadExecutor threadExecutor,
                                      PostExecutionThread postExecutionThread,
                                      PlaceDataProvider placeDataProvider) {

         super(threadExecutor, postExecutionThread);
         this.placeDataProvider = placeDataProvider;
     }


     @Override
     protected Observable buildUseCaseObservable() {
         return Observable.zip(queryObservable, offsetObservable, (query, offset) ->
                 placeDataProvider.getPlacesRemote(query, offset, LIMIT)
                         .map(places -> toIds(places))
                         .flatMap(ids -> placeDataProvider.getPlacesByIdsLocal(ids)));

     }


 }