yzc261亚洲城官网备用地址初入RX,有一个需求不知道咋写?

( yzc261亚洲城官网备用地址 )

需求是如许的:我需求开启一个定时器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);

尚未找出缘由,但我找到一个交换版本:

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

(看完/读完)这篇文章有何感想! yzc261亚洲城官网备用地址的分享…

发表评论

电子邮件地址不会被公开。 必填项已用*标注