基于Rxjava实现轮询定时器
2018-06-28 11:20
676 查看
本文实例为大家分享了Rxjava实现轮询定时器的具体代码,供大家参考,具体内容如下
作用
1、实现了延迟若干毫秒后,执行next操作,只执行一次
2、实现了每隔若干毫秒后,执行next操作,可执行多次
工具类源码
/** * Copyright 2015-2018 Hive Box. */ package com.fcbox.locker.shrail.utils; import android.support.annotation.NonNull; import com.fcbox.locker.sdk.Locker; import com.fcbox.locker.sdk.log.LogUtils; import java.util.concurrent.TimeUnit; import io.reactivex.Observable; import io.reactivex.Observer; import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.disposables.Disposable; /** * Rxjava2.x实现轮询定时器. * * @author xuzhuyun */ public class RxTimerUtil { private static Disposable mDisposable; /** * milliseconds毫秒后执行next操作 */ public static void timer(long milliseconds, final IRxNext next) { Observable.timer(milliseconds, TimeUnit.MILLISECONDS) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer<Long>() { @Override public void onSubscribe(@NonNull Disposable disposable) { mDisposable = disposable; } @Override public void onNext(@NonNull Long number) { if (next != null) { next.doNext(number); } } @Override public void onError(@NonNull Throwable e) { //取消订阅 cancel(); } @Override public void onComplete() { //取消订阅 cancel(); } }); } /** * 每隔milliseconds毫秒后执行next操作 */ public static void interval(long milliseconds, final IRxNext next) { Observable.interval(milliseconds, TimeUnit.MILLISECONDS) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer<Long>() { @Override public void onSubscribe(@NonNull Disposable disposable) { mDisposable = disposable; } @Override public void onNext(@NonNull Long number) { if (next != null) { next.doNext(number); } } @Override public void onError(@NonNull Throwable e) { } @Override public void onComplete() { } }); } /** * 取消订阅 */ public static void cancel() { if (mDisposable != null && !mDisposable.isDisposed()) { mDisposable.dispose(); LogUtils.e("====Rx定时器取消======"); } } public interface IRxNext { void doNext(long number); } }
调用
调用时相应的类需要实现IRxNext接口,在doNext方法中实现自己的逻辑即可。另外记得用完后调用cancel方法取消订阅。
致谢
原文出处已经找不到了,在此感谢原作者。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。
您可能感兴趣的文章:
相关文章推荐
- 基于升序链表的定时器实现
- 基于RxJava实现事件总线
- 轻松实现Rxjava定时器功能
- 基于c#中Timer实现定时器功能
- 基于委托机制的定时器的实现
- 使用RxJava来实现网络请求轮询功能
- 基于jquery,php实现AJAX长轮询(LongPoll)
- Renovace :一款基于Retrofit & RxJava 实现简单易用的网络请求框架
- 基于jQuery与PHP实现Ajax长轮询(LongPoll)
- C之基于signal实现定时器的demon
- 使用RxJava实现定时器功能
- javascript基于定时器实现进度条功能实例
- Retrofit+Rxjava服务器IP轮询重试机制实现
- 基于HashedWheelTimer的一个定时器实现
- 基于DNS轮询实现Web站点的负载均衡
- 用 ASP.NET MVC 实现基于 XMLHttpRequest long polling(长轮询) 的 Comet
- 获取验证码辅助类(基于RxJava框架实现)
- 基于jquery,php实现AJAX长轮询(LongPoll)
- java cache过期策略两种实现,一个基于list轮询一个基于timer定时
- 【Dev Club分享】基于RxJava的一种MVP实现