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 ialah pengulangan, bukan berulang pada selang masa tetap, gunakan selang
2.tunda adalah untuk menangguhkan pelepasan untuk mengulangi selepas kelewatan, bukan mengikut parameter kelewatan pengulangan
3. Penyelesaiannya adalah dengan menggunakan selang, yang boleh menentukan kelewatan awal dan selang ulangan, ditambah dengan operasi ambil dan peta, ambil 10 yang pertama dan tukarkannya menjadi kira detik

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

Answer 2

Belum mengetahui puncanya lagi, tetapi saya menemui versi alternatif:

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

Ini ialah kira detik, dan kemudian tambahkan kelewatan di hadapan:

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