java - 订阅 Observable 不会执行任何操作

Question

我试图了解 Observables 是如何执行的，但似乎无法让这个简单的代码工作。

public class RxJavaExample {
    public static void main(String[] args) {
        Observable<String> hello = Observable.fromCallable(() -> 
            getHello()).subscribeOn(Schedulers.newThread());

        hello.subscribe();

        System.out.println("End of main!");
    }

    public static String getHello() {
        System.out.println("Hello called in " + 
            Thread.currentThread().getName());
        return "Hello";
    }
}

hello.subscribe()不应该执行getHello()吗？

Answer 1

这是因为您的主线程在后台线程到达 getHello 之前完成。退出之前尝试在 main 方法中添加 Thread.sleep(5000) 。

或者，等待订阅的 onCompleted 被调用。

编辑:程序终止的原因是因为 RxJava 产生 daemon线程。在寻找好的来源时，我还发现了this问题，它也可能回答它。