java - 试图理解 subscribeActual()

Question

This question问我想知道的，但答案没有解释。有人可以分享一个具体示例来说明如何使用 subscribeActual() 与 subscribe() 吗？

Answer 1

我想我可能已经弄明白了。请给出意见:当您编写自定义 Observable 时，您可以通过扩展基类来实现。但是您希望用户能够以正常方式subscribe()。因此，基类只是将调用转发给您的 subscribeActual() 方法，该方法执行实际的订阅工作。