以不同的时间间隔调用网络服务？

Question

我是 Rx android 的新手。我正在尝试以不同的时间间隔调用 Web 服务。

每 1 分钟调用 Api 4 小时，持续 30 分钟，然后每 5 分钟调用一次，持续 3 小时 30 分钟

是否可以使用 Rx android。如果可能的话，请告诉我该怎么做？

 Observable.interval(1,TimeUnit.MINUTES).takeWhile(Observable.timer(30,TimeUnit.MINUTES).concatWith(Observable.interval(5,TimeUnit.MINUTES).takeWhile(Observable.timer(30,TimeUnit.MINUTES).flatMap(new Func1<Long, Observable<?>>() {
            @Override
            public Observable<?> call(Long aLong) {
                return null;
            }
        }).subscribe((new Observer<Object>() {
            @Override
            public void onCompleted() {
                Log.e("working", "onCompleted");
            }

            @Override
            public void onError(Throwable e) {
                Log.e("working", "onComThrowablepleted");
            }

            @Override
            public void onNext(Object o) {
                Log.e("working", "onNext");

            }
        });
        ))

Answer 1

您可以使用interval、takeUntil、timer 和concatWith：想法是使用interval 并在30 分钟后停止它，然后使用另一个interval。

 // 1 events per minutes
 Observable.interval(1, MINUTES)
           // and stop it after 30 minutes
           .takeUntil(Observable.timer(30, MINUTES))
           // then 1 events per 5 minutes, and stop it after 30 minutes
           .concatWith(Observable.interval(5, MINUTES).takeUntil(Observable.timer(30, MINUTES)))
           // perform webservice call
           .flatMap(time -> webservice.call())
           .subscribe();