rx-java - 为什么你不应该使用 Observable.create

Question

我在许多 Rxjava 教程中看到，不鼓励使用 Observable.create 方法来创建 Observable。相反，最好使用 Observable.fromCallable 或 Observable.just 来发出单个对象。使用 Observable.create 作为最后一个选项。这是为什么？问题之一是背压的处理。使用 create 是否存在其他风险？谁能用一些例子来解释一下以便更好地理解？我没有从任何教程中得到这个问题的正确解释，这就是我在这里问的原因。提前致谢

Answer 1

不是关于鼓励，而是关于 if create 运算符调整您需要的内容。create 运算符让您可以选择实现 onNext 或 onError

   @Test
    public void testCreateObservableNext() {
        Observable.create(observer -> {
            observer.onNext("Injected value on Next");
            observer.onError(new NullPointerException("This is the final exception"));

    }).map(s -> ((String) s).toUpperCase())
            .subscribe(System.out::println, System.out::println);
}

如果您不需要，just 或 fromCallable 就可以了。

您可以在此处查看创建运算符的示例 https://github.com/politrons/reactive/blob/master/src/test/java/rx/observables/creating/ObservableCreate.java