rxjava2: Flowable.unsafeCreate()与Flowable.fromPublisher()

Question

如果我按照反应性规范实现自己的Publisher<T>：

Publisher<Object> publisher = new MyAwesomelyReactivePublisher<>();

现在，我想将它与rxJava2可流连接起来，两者之间的区别是：

Flowable.unsafeCreate(publisher);

和

Flowable.fromPublisher(publisher);

两者的用例是什么？读Javadoc对我没什么帮助。

Answer 1

您忽略了一个JavaDoc差异：

unsafeCreate

抛出: IllegalArgumentException --如果onSubscribe是一个可流动的子类；这样的实例不需要转换，并且可能是1.x中的端口残余，或者应该使用hide()。

除此之外，它们是以同样的方式实施的：

https://github.com/ReactiveX/RxJava/blob/2.x/src/main/java/io/reactivex/Flowable.java#L2131 https://github.com/ReactiveX/RxJava/blob/2.x/src/main/java/io/reactivex/Flowable.java#L4257