Rxjava定时功能

使用RxJava实现定时器功能可以通过两种方式来实现，具体实现如下：

一、使用timer

private Disposable mDisposable;

    /**
     * 启动定时器
     */
    public void startTime() {

     Observable.timer(10, TimeUnit.SECONDS)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<Long>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        mDisposable = d;
                    }

                    @Override
                    public void onNext(Long value) {
                        //Log.d("Timer",""+value);
                    }

                    @Override
                    public void onError(Throwable e) {

                    }

                    @Override
                    public void onComplete() {
                       // TODO:2017/12/1
                        closeTimer();
                    }
                });
    }


    /**
     * 关闭定时器
     */
    public void closeTimer(){
        if (mDisposable != null) {
            mDisposable.dispose();
        }
    }

二、使用使用interval 和 take

在1.x 中 ​​timer​​ 可以执行间隔逻辑，在2.x中此功能已过时，交给了 ​​interval​​ 操作符,当然只使用 ​​interval​​ 还不能实现定时器功能，必须再结合​​take​​

private Disposable mDisposable;

    /**
     * 启动定时器
     */
    public void startTime() {
     int count_time = 10; //总时间
     Observable.interval(0, 1, TimeUnit.SECONDS)
                .take(count_time+1)//设置总共发送的次数
                .map(new Function<Long, Long>() {
                    @Override
                    public Long apply(Long aLong) throws Exception {
                        //aLong从0开始
                        return  count_time-aLong;
                    }
                })
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Observer<Long>() {
                    @Override
                    public void onSubscribe(Disposable d) {
                        mDisposable = d;
                    }

                    @Override
                    public void onNext(Long value) {
                        //Log.d("Timer",""+value);
                    }

                    @Override
                    public void onError(Throwable e) {

                    }

                    @Override
                    public void onComplete() {
                       // TODO:2017/12/1
                        closeTimer();
                    }
                });
    }


    /**
     * 关闭定时器
     */
    public void closeTimer(){
        if (mDisposable != null) {
            mDisposable.dispose();
        }
    }