android - 初入RX，有一个需求不知道咋写？

问题描述

问 题

需求是这样的：我需要开启一个定时器A，当A定时到50秒的时候，开始开启第二个定时器B，A结束，B开始倒数10秒，每一秒发出一个通知：
然后，我用RX这样做了：

Observable<Long> observable =
                Observable
                        .timer(50, TimeUnit.SECONDS)
                        .repeat(10)
                        .delay(1,TimeUnit.SECONDS);

        subscription = observable
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(aLong -> {
                    //发通知倒计时
                    Log.e("note","flag");
                });

想了半天，好像没啥问题，但是跑起来就有问题了，发现，50秒时挺准的，然后到了第二个定时器，也就是.repeat(10),最后打印的，按照理想，应该是每隔一秒打印，但是实际上相隔了好多秒！。。。
找了半天也没找出啥，难道是我理解错误这几个操作符了？求救大神！

解决方案

1.repeat是重复，不是间隔固定时间进行重复，间隔固定时间的，用interval
2.delay是延迟发布，在repeat之后加delay,是在延迟后重复，而不是按delay参数进行间隔重复
3.解决方案是用 interval，可以指定初始延迟，重复间隔，再加上take和map操作，取前10个并转换成倒计时

Observable.interval(50, 1, TimeUnit.SECONDS)//延迟50s,然后每1秒重复
          .take(10)//取10个
          .map(aLong -> 10 - aLong)//转换成倒计时
          .subscribe(YOUR_ACTION);

这篇关于android - 初入RX，有一个需求不知道咋写？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！