RxJava Scheduler在主线程上观察

Question

如果我写这样的事情,那么这两个操作和通知将是对当前线程...

Observable.fromCallable(() -> "Do Something")
    .subscribe(System.out::println);

如果我在后台线程这样的操作,那么这两个操作和通知将在后台线程...

Observable.fromCallable(() -> "Do Something")
    .subscribeOn(Schedulers.io())
    .subscribe(System.out::println);

如果我想在主线程上观察并在Android中执行后台我会做...

Observable.fromCallable(() -> "Do Something")
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(System.out::println);

但是如果我正在编写一个标准的Java程序,那么你想在主线程上观察到的状态是什么呢？

Answer 1

对于RxJava2，请使用“ blockingSubscribe()”

Flowable.fromArray(1, 2, 3)
                .subscribeOn(Schedulers.computation())
                .blockingSubscribe(integer -> {
                    System.out.println(Thread.currentThread().getName());
                });

Answer 2

将转换Observable为BlockingObservablevia .toBlocking(); 这为您提供了等待完成，获得一件物品等的阻塞方法。