亚洲城娱乐初入RX,有一个需求不知道咋写?

( 亚洲城娱乐 )

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

Observable<Long> observable =
                Observable
                        .timer50, TimeUnit.SECONDS
                        .repeat10
                        .delay1,TimeUnit.SECONDS;

        subscription = observable
                .observeOnAndroidSchedulers.mainThread
                .subscribeaLong -> {
                    //发通知倒计时
                    Log.e"note","flag";
                };

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

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

Observable.interval50, 1, TimeUnit.SECONDS//延迟50s,然后每1秒重复
          .take10//取10个
          .mapaLong -> 10 - aLong//转换成倒计时
          .subscribeYOUR_ACTION;

尚未找出原因,但我找到一个替代版本:

/**
     * 倒计时,倒计 time 秒
     * @param time  单位:秒
     * @return  Observable
     */
    public static Observable<Integer> countDownint time {
        if time < 0 time = 0;
        final int countTime = time;
        return Observable.interval0, 1, TimeUnit.SECONDS
                .subscribeOnSchedulers.newThread
                .mapincreaseTime -> countTime - increaseTime.intValue
                .takecountTime + 1;
    }

这是一个倒计时,然后,在前面加上延时就可以了:

private final static int TheMaxRecordTime = 60;     //最大录音时长:秒
private final static int NoteUserRecordTime = 10;   //剩余多少秒开始提示用户
 Observable<Integer> observable = Observable
                .timerTheMaxRecordTime-NoteUserRecordTime+2, TimeUnit.SECONDS
                .flatMapaLong -> RxUtils.countDownNoteUserRecordTime;

        subscription = observable
                .observeOnAndroidSchedulers.mainThread
                .subscribeaLong -> {
                    setLeftTimeaLong;
                    if aLong==0
                        EventBus.getDefault.postnew EventMsgEventMsg.MessageType.Record_Time_Out;
                };

(看完/读完)这篇文章有何感想! 亚洲城娱乐的分享…

发表评论

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