RXJava x saat sonra nasıl elde edilmeye çalışılır

Question

Y koşulu yükseltilene kadar her x saniyede bir güçlendirme kullanarak bir web servisine çağrı yapmak istiyorum.

Yanıt null olana kadar x saniye sonra OrderApi.get çalıştırmak istiyorum.

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


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

Zaten Observable.delay Observable.timber gibi operatörler gördüm ama düzgün kullanmak için bir yol bulamıyorum.

Answer 1

bu durdurmak için

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

timer ve repeat bir arada o

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()); 
      } 
     }); 

geri arama call her 1 sn