美文网首页
RxJava2.x-timer

RxJava2.x-timer

作者: 河马过河 | 来源:发表于2018-08-18 10:33 被阅读390次

    一、RxJava-timer语法

        public void rxJavaTimeExample() {
            LogUtils.error(TAG, "rxJavaTimeExample--start--:" + Thread.currentThread().getName() + "--:" + TimeUtils.getNowString());
            Disposable disposable = Observable.timer(4, TimeUnit.SECONDS)
                    .subscribeOn(Schedulers.io())
                    .unsubscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(new Consumer<Long>() {
                        @Override
                        public void accept(Long aLong) throws Exception {
                            LogUtils.error(TAG, "rxJavaTimeExample--end--:" + Thread.currentThread().getName() + "--:" +TimeUtils.getNowString()+"---long:"+aLong);
                        }
                    });
            compositeDisposable.add(disposable);
        }
    

    日志

    08-18 10:28:55.678 4505-4505/com.example.zhang E/MainPresenter: rxJavaTimeExample--start--:main--:2018-08-18 10:28:55
    08-18 10:28:59.852 4505-4505/com.example.zhang E/MainPresenter: rxJavaTimeExample--end--:main--:2018-08-18 10:28:59---long:0
    

    总结

    1、timer(long delay, TimeUnit unit) delay 延迟时间 unit 时间单位
    2、timer属于类方法 ,delay属于对象方法


    河马过河微信公众号.jpg

    相关文章

      网友评论

          本文标题:RxJava2.x-timer

          本文链接:https://www.haomeiwen.com/subject/veaxiftx.html