问题描述
需求是这样的：我需要开启一个定时器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：1.repeat是重复，不是间隔固定时间进行重复，间隔固定时间的，用interval2.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);回答2：
尚未找出原因，但我找到一个替代版本：
/** * 倒计时，倒计 time 秒 * @param time 单位：秒 * @return Observable */ public static Observable<Integer> countDown(int time) {if (time < 0) time = 0;final int countTime = time;return Observable.interval(0, 1, TimeUnit.SECONDS).subscribeOn(Schedulers.newThread()).map(increaseTime -> countTime - increaseTime.intValue()).take(countTime + 1); }
这是一个倒计时，然后，在前面加上延时就可以了：
private final static int TheMaxRecordTime = 60; //最大录音时长：秒private final static int NoteUserRecordTime = 10; //剩余多少秒开始提示用户 Observable<Integer> observable = Observable.timer(TheMaxRecordTime-NoteUserRecordTime+2, TimeUnit.SECONDS).flatMap((aLong -> RxUtils.countDown(NoteUserRecordTime)));subscription = observable.observeOn(AndroidSchedulers.mainThread()).subscribe(aLong -> { setLeftTime(aLong); if (aLong==0)EventBus.getDefault().post(new EventMsg(EventMsg.MessageType.Record_Time_Out));});
