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

Question

需求是这样的：我需要开启一个定时器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),最后打印的，按照理想，应该是每隔一秒打印，但是实际上相隔了好多秒！。。。
找了半天也没找出啥，难道是我理解错误这几个操作符了？求救大神！

Answer 1

1.repeat est une répétition, non répétée à intervalles fixes. Pour des intervalles fixes, utilisez l'intervalle
2.delay consiste à retarder la libération pour répéter après un délai, et non en fonction du paramètre de retard. répétition
3. La solution consiste à utiliser l'intervalle, qui peut spécifier le délai initial et l'intervalle de répétition, ainsi que les opérations de prise et de cartographie, prendre les 10 premiers et les convertir en compte à rebours

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

Answer 2

Je n'ai pas encore trouvé la cause, mais j'ai trouvé une version alternative :

/**
     * 倒计时，倒计 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);
    }

C'est un compte à rebours, puis ajoutez simplement un délai devant :

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