Rxjava的线程调度

调度器

用于线程调度

使用案例

Observable.create(new Observable.OnSubscribe<String>() {

 @Override
 public void call(Subscriber<? super String> subscriber) {
  System.out.println("正在进行耗时操作");
  subscriber.onNext("执行耗时操作后的结果");

h7ml
  • android
  • rxjava
大约 2 分钟
RxJava的优势
public class MainActivity extends AppCompatActivity {

    private ImageView mImageView;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);

h7ml
  • android
  • rxjava
大约 1 分钟
rxjava

添加依赖

compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
compile 'io.reactivex.rxjava2:rxjava:2.0.1'

创建数据源(被观察者/可观察者)

返回一个可观察对象,该对象发出给定(常量引用)项的信号,然后完成

just 方法

Observable.just(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)

h7ml
  • android
  • rxjava
大约 6 分钟