RxJava操作符实践:1_创建操作之10_timer

一、描述

创建一个Observable,它在一个给定的延迟后发射一个特殊的值。

Timer操作符创建一个在给定的时间段之后返回一个特殊值的Observable。

timer返回一个Observable,它在延迟一段给定的时间后发射一个简单的数字0。

timer操作符默认在computation调度器上执行。有一个变体可以通过可选参数指定Scheduler。

二、示意图

timer

三、示例代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
Observable.timer(3, TimeUnit.SECONDS)
.subscribe(new Subscriber<Long>() {
@Override
public void onCompleted() {
System.out.println("onCompleted.");
}

@Override
public void onError(Throwable e) {
System.out.println("onError: " + e.getMessage());
}

@Override
public void onNext(Long aLong) {
System.out.println("onNext: " + aLong);
}
});

四、运行结果

延时3秒后,打印出如下信息:

1
2
onNext: 0
onCompleted.

项目代码已上传到Github:https://github.com/SherlockShi/RxJavaBestPractise

五、参考资料

ReactiveX官方文档

ReactiveX文档中文翻译

PS:欢迎关注 SherlockShi 个人博客

感谢你的支持,让我继续努力分享有用的技术和知识点!