RXJava 如何尝试在 x 时间后获得下一个 [英] RXJava how to try to get next after x time

问题描述

我想每隔 x 秒调用一次 Web 服务，直到出现 y 条件.

I wan to do a call to a web service using retrofit every x seconds until y condition is raised.

我想在 x 秒后运行 OrderApi.get 直到响应为空.

I want to run OrderApi.get after x seconds until the response is null.

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


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

已经看到像 Observable.delay Observable.timber 这样的操作符，但我找不到正确使用它们的方法.

Already saw operators like Observable.delay Observable.timber but I cant find a way to use them properly.

推荐答案

这应该可行

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

这篇关于RXJava 如何尝试在 x 时间后获得下一个的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！