基于Rxjava实现轮询定时器
作者:hgncxzy_
这篇文章主要为大家详细介绍了基于Rxjava实现轮询定时器,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
本文实例为大家分享了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方法取消订阅。
致谢
原文出处已经找不到了,在此感谢原作者。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。