RxJava2 / RxAndroid2操作符interval:每隔若干时间发射信号
Interval每隔一定时间发射一个整数,从0开始,例如:
package zhangphil.app; import android.os.Bundle; import android.support.annotation.Nullable; import android.support.v7.app.AppCompatActivity; import android.util.Log; import java.util.concurrent.TimeUnit; import io.reactivex.Observable; import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.disposables.CompositeDisposable; import io.reactivex.observers.DisposableObserver; import io.reactivex.schedulers.Schedulers; public class MainActivity extends AppCompatActivity { private final String TAG = getClass().getSimpleName(); private CompositeDisposable mCompositeDisposable = new CompositeDisposable(); ; @Override public void onCreate(@Nullable Bundle savedInstanceState) { super.onCreate(savedInstanceState); test(); } private void test() { mCompositeDisposable.add(Observable.interval(0, 5, TimeUnit.SECONDS) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribeWith(getObserver(1))); } private DisposableObserver getObserver(final int id) { DisposableObserver disposableObserver = new DisposableObserver<Object>() { @Override public void onNext(Object o) { Log.d(id + TAG, "#####开始#####"); Log.d(id + "数据", String.valueOf(o)); Log.d(id + TAG, "#####结束#####"); } @Override public void onComplete() { Log.d(id + TAG, "onComplete"); } @Override public void onError(Throwable e) { Log.e(id + TAG, e.toString(), e); } }; return disposableObserver; } @Override protected void onDestroy() { super.onDestroy(); // 如果退出程序,就清除后台任务 mCompositeDisposable.clear(); } }
代码输出:
05-18 17:10:58.436 8466-8466/? D/1MainActivity: #####开始##### 05-18 17:10:58.436 8466-8466/? D/1数据: 0 05-18 17:10:58.436 8466-8466/? D/1MainActivity: #####结束##### 05-18 17:10:58.439 8466-8466/? W/Activity: AppLock checkAppLockState locked:false verifying:false pkgName = zhangphil.app isInMultiWindowMode:false 05-18 17:10:58.457 8466-8502/? I/Adreno: QUALCOMM build : 5451aae, I25dc76dc3f Build Date : 01/02/17 OpenGL ES Shader Compiler Version: XE031.09.00.03 Local Branch : Remote Branch : refs/tags/AU_LINUX_ANDROID_LA.UM.5.5.R1.07.00.00.269.013 Remote Branch : NONE Reconstruct Branch : NOTHING 05-18 17:10:58.478 8466-8502/? I/OpenGLRenderer: Initialized EGL, version 1.4 05-18 17:10:58.478 8466-8502/? D/OpenGLRenderer: Swap behavior 1 05-18 17:10:58.482 8466-8466/? D/ViewRootImpl@15edd34[MainActivity]: MSG_RESIZED_REPORT: ci=Rect(0, 81 - 0, 0) vi=Rect(0, 81 - 0, 0) or=1 05-18 17:10:58.482 8466-8466/? D/ViewRootImpl@15edd34[MainActivity]: MSG_WINDOW_FOCUS_CHANGED 1 05-18 17:10:58.482 8466-8466/? I/InputMethodManager: [IMM] startInputInner - mService.startInputOrWindowGainedFocus 05-18 17:10:58.485 8466-8502/? D/libGLESv1: STS_GLApi : DTS is not allowed for Package : zhangphil.app 05-18 17:10:58.488 8466-8479/? D/InputTransport: Input channel constructed: fd=73 05-18 17:11:03.321 8466-8466/zhangphil.app D/1MainActivity: #####开始##### 05-18 17:11:03.321 8466-8466/zhangphil.app D/1数据: 1 05-18 17:11:03.321 8466-8466/zhangphil.app D/1MainActivity: #####结束##### 05-18 17:11:08.321 8466-8466/zhangphil.app D/1MainActivity: #####开始##### 05-18 17:11:08.321 8466-8466/zhangphil.app D/1数据: 2 05-18 17:11:08.322 8466-8466/zhangphil.app D/1MainActivity: #####结束##### 05-18 17:11:13.321 8466-8466/zhangphil.app D/1MainActivity: #####开始##### 05-18 17:11:13.321 8466-8466/zhangphil.app D/1数据: 3 05-18 17:11:13.322 8466-8466/zhangphil.app D/1MainActivity: #####结束##### 05-18 17:11:18.321 8466-8466/zhangphil.app D/1MainActivity: #####开始##### 05-18 17:11:18.321 8466-8466/zhangphil.app D/1数据: 4 05-18 17:11:18.321 8466-8466/zhangphil.app D/1MainActivity: #####结束##### 05-18 17:11:23.321 8466-8466/zhangphil.app D/1MainActivity: #####开始##### 05-18 17:11:23.322 8466-8466/zhangphil.app D/1数据: 5 05-18 17:11:23.322 8466-8466/zhangphil.app D/1MainActivity: #####结束##### 05-18 17:11:28.321 8466-8466/zhangphil.app D/1MainActivity: #####开始##### 05-18 17:11:28.322 8466-8466/zhangphil.app D/1数据: 6 05-18 17:11:28.322 8466-8466/zhangphil.app D/1MainActivity: #####结束#####
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
Android Studio上NDK编程步骤与演示
Android Studio上NDK编程步骤与演示 在AndroidStudio(AS)上搞NDK编程首先要下载与安装NDK,搞好了这步之后。只需要以下几步配置与操作就可以轻松开始NDK编程与运行。 新建一个纯Android项目(不包含C++支持) 在新项目中创建一个新Java文件为BitmapProcessor.java, 定义两个本地方法,代码实现如下: package com.gloomyfish.ndkdemo; import android.graphics.Bitmap; /** * Created by jia20003 on 2017/5/18. */ public class BitmapProcessor { static { System.loadLibrary("BitmapProcessor"); } public native void gray(Bitmap bm); public native void inverse(Bitmap bm); } 编译含有本地方法的Java文件和产生.h的C++文件 首先新建一个bat脚本文件javahrun.bat然后...
- 下一篇
使用Kotlin开发Android应用初体验
使用Kotlin开发Android应用初体验 昨晚,最近一届的谷歌IO大会正式将Kotlin确定为了官方开发语言,作为一名Android开发鸟,怎么能不及时尝尝鲜呢? Kotlin的简要介绍 在开发之前,很多同学一定有很多疑问,Kotlin到底有啥好处,怎么和现有的项目共存呢?Java那么些特性Kotlin都有吗?嗯,让我们一一来看。 以下内容摘自:Kotlin的官方网站:https://www.kotlincn.net/docs/reference/android-overview.html Kotlin 非常适合开发 Android 应用程序,将现代语言的所有优势带入 Android 平台而不会引入任何新的限制: 兼容性:Kotlin 与 JDK 6 完全兼容,保障了 Kotlin 应用程序可以在较旧的 Android 设备上运行而无任何问题。Kotlin 工具在 Android Studio 中会完全支持,并且兼容 Android 构建系统。 性能:由于非常相似的字节码结构,Kotlin 应用程序的运行速度与 Java 类似。 随着 Kotlin 对内联函数的支持,使用 lamb...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- CentOS关闭SELinux安全模块
- SpringBoot2整合Redis,开启缓存,提高访问速度
- Docker安装Oracle12C,快速搭建Oracle学习环境
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- SpringBoot2初体验,简单认识spring boot2并且搭建基础工程
- Linux系统CentOS6、CentOS7手动修改IP地址
- CentOS8安装Docker,最新的服务器搭配容器使用
- CentOS7,8上快速安装Gitea,搭建Git服务器
- CentOS7编译安装Cmake3.16.3,解决mysql等软件编译问题
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果