RxJava 创建操作符
下面是用于创建Observable的操作符。
序号 | 操作符和描述 |
---|---|
1 | Create 从头开始创建Observable,并允许观察者方法以编程的方式调用。 |
2 | Defer 在观察者订阅之前不创建Observable。为每个观察者创建一个新的observable。 |
3 | Empty/Never/Throw 创建一个具有有限行为的Observable。 |
4 | From 将对象/数据结构转换为Observable。 |
5 | Interval 创建一个以指定时间间隔发出整数序列的Observable。 |
6 | Just 将对象/数据结构转换为Observable,以发出相同或相同类型的对象。 |
7 | Range 创建一个以给定范围发出整数序列的Observable。 |
8 | Repeat 重复发出整数序列的Observable。 |
9 | Start 创建一个发出函数返回值的Observable。 |
10 | Timer 创建一个在给定延迟后发出单个项目的Observable。 |
创建操作符示例
使用您选择的任何编辑器在C:> RxJava中创建以下Java程序。
ObservableTester.java
验证结果
使用 javac 编译器编译以下类:
现在按照以下方式运行ObservableTester −
它应该产生以下输出 –