RXJava, jak spróbować uzyskać następną po X czasie

Question

Chcę wykonać połączenie z serwisem internetowym za pomocą modernizacji co x sekund, aż stan Y zostanie podniesiony.

Chcę uruchomić OrderApi.get po x sekundach, aż odpowiedź będzie pusta.

public class OrderApi {} 
    public static Observable<Order> get() { 
     //... 
    } 
} 


OrderApi.get(order.getId())) 
     .subscribe(updatedOrder -> { 
      mShouldRun = updatedOrder != null; 
     }); 

Już operatorów pił jak Observable.delayObservable.timber ale nie mogę znaleźć sposób, aby ich używać prawidłowo.

Answer 1

to powinno działać

Observable.interval(1, TimeUnit.SECONDS) 
       .flatMap(new Func1<Long, Observable<?>>() { 
        @Override 
        public Observable<?> call(Long aLong) { 
         return OrderApi.get(); 
        } 
       }).takeUntil(new Func1<Object, Boolean>() { 
      @Override 
      public Boolean call(Object o) { 
       return o==null; 
      } 
     }).subscribe(observer); 

Answer 2

kombinacja timer i repeat powinien zrobić to

Observable.timer(1000, TimeUnit.MILLISECONDS) 
     .subscribeOn(Schedulers.io()) 
     .observeOn(AndroidSchedulers.mainThread()) 
     .repeat(Schedulers.io()) 
     .subscribe(new Action1<Object>() { 
      @Override 
      public void call(Object aLong) { 
       System.out.println(System.currentTimeMillis()); 
      } 
     }); 

callback call nazywa co 1 sek